mirror of
https://github.com/ClickHouse/ClickHouse.git
synced 2024-09-21 01:00:48 +00:00
Merge pull request #5285 from abyss7/issue-5085
Don't crash the server when Kafka consumers have failed to start
This commit is contained in:
commit
81ed764d6a
@ -126,8 +126,15 @@ void StorageKafka::startup()
|
||||
for (size_t i = 0; i < num_consumers; ++i)
|
||||
{
|
||||
// Make buffer available
|
||||
pushBuffer(createBuffer());
|
||||
++num_created_consumers;
|
||||
try
|
||||
{
|
||||
pushBuffer(createBuffer());
|
||||
++num_created_consumers;
|
||||
}
|
||||
catch (const cppkafka::Exception &)
|
||||
{
|
||||
tryLogCurrentException(log);
|
||||
}
|
||||
}
|
||||
|
||||
// Start the reader thread
|
||||
|
Loading…
Reference in New Issue
Block a user