Skip to content

Commit

Permalink
Suppress error from rd_kafka_conf_set while setting enable.manual.eve…
Browse files Browse the repository at this point in the history
…nts.poll
  • Loading branch information
KiillThemAll authored and kenneth-jia committed Feb 13, 2023
1 parent 6ba7331 commit 6b8ec71
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion include/kafka/KafkaClient.h
Original file line number Diff line number Diff line change
Expand Up @@ -292,7 +292,7 @@ KafkaClient::KafkaClient(ClientType clientType,
const Properties& properties,
const ConfigCallbacksRegister& extraConfigRegister)
{
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" };

// Save clientID
if (auto clientId = properties.getProperty(Config::CLIENT_ID))
Expand Down

0 comments on commit 6b8ec71

Please sign in to comment.