We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 6ba7331 commit 6b8ec71Copy full SHA for 6b8ec71
include/kafka/KafkaClient.h
@@ -292,7 +292,7 @@ KafkaClient::KafkaClient(ClientType clientType,
292
const Properties& properties,
293
const ConfigCallbacksRegister& extraConfigRegister)
294
{
295
- static const std::set<std::string> PRIVATE_PROPERTY_KEYS = { "max.poll.records" };
+ static const std::set<std::string> PRIVATE_PROPERTY_KEYS = { "max.poll.records", "enable.manual.events.poll" };
296
297
// Save clientID
298
if (auto clientId = properties.getProperty(Config::CLIENT_ID))
0 commit comments