parveenbadoni

Hi, I want to pass header alongwith message. I need to pass authentication token in header. Is there a way to pass header? Can someone please help?

How can i change value of enable.auto.commit to false?

Consumer not reading messages after restart

4

Following is my Consumer and Producer Script : **Consumer Script** $config = ConsumerConfig::getInstance(); $config->setMetadataRefreshIntervalMs(10000); $config->setMetadataBrokerList('localhost:9092'); $config->setGroupId('test'); $config->setBrokerVersion('1.1.1'); $config->setTopics(['Request']); $config->setOffsetReset('earliest'); $consumer = new Consumer(); $consumer->setLogger($logger); $consumer->start(function($topic, $part, $message) { var_dump($message); });...