Consumer not reading messages after restart

[parveenbadoni]

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);
});

Producer Script
$config = ProducerConfig::getInstance();
$config->setMetadataRefreshIntervalMs(10000);
$config->setMetadataBrokerList('localhost:9092');
$config->setBrokerVersion('1.1.1');
$config->setRequiredAck(1);
$config->setIsAsyn(false);
$config->setProduceInterval(500);
$producer = new \Kafka\Producer(
function() {
return [
[
'topic' => 'Request',
'value' => 'My Test Data',
],
];
}
);
$producer->success(function($result) {
var_dump($result);
});
$producer->error(function($errorCode) {
var_dump($errorCode);
});
$producer->send(true);

It is working fine. When consumer is running and producer is publishing data, consumer is able to read it. But once i stop consumer and then publish data and then start consumer, Consumer does not read that data. What am i doing wrong? Can someone help?

[parveenbadoni]

@lcobucci Can you please help?

[lcobucci]

@parveenbadoni sorry I can't 😞 this lib has some connection management issues that aren't that trivial to fix without big changes (IMHO). I've decided to focus on other projects then.

[parveenbadoni]

@parveenbadoni sorry I can't 😞 this lib has some connection management issues that aren't that trivial to fix without big changes (IMHO). I've decided to focus on other projects then.

Its ok @lcobucci :)
Can you please recommend someone else who might help me in this issue

[parveenbadoni]

Hi @nmred, Can you please guide me where i am going wrong.