readd setKafkaConfigurationField(*conf_, "client.id", this->getUUIDStr());

Author: martinzink

extensions/kafka/ConsumeKafka.cpp

@@ -131,7 +131,7 @@ void ConsumeKafka::configureNewConnection(api::core::ProcessContext& context) {
   setKafkaConfigurationField(*conf_, "enable.auto.offset.store", std::to_string(commit_policy_ == consume_kafka::CommitPolicyEnum::AutoCommit));
   setKafkaConfigurationField(*conf_, "isolation.level", utils::parseBoolProperty(context, HonorTransactions) ? "read_committed" : "read_uncommitted");
   setKafkaConfigurationField(*conf_, "group.id", utils::parseProperty(context, GroupID));
-  // setKafkaConfigurationField(*conf_, "client.id", client_id); No need to set id since its autogenerated, and we don't access it anywhere from minifi
+  setKafkaConfigurationField(*conf_, "client.id", this->getUUIDStr());
   setKafkaConfigurationField(*conf_, "session.timeout.ms", std::to_string(utils::parseDurationProperty(context, SessionTimeout).count()));
   // Twice the default, arbitrarily chosen
   setKafkaConfigurationField(*conf_, "max.poll.interval.ms", "600000");