sauravaggarwal

Hi, Thanks for update.Using below configuration for consuming the messages. But getting single message. $conf = new \RdKafka\Conf(); $conf->set('group.id', 'testing'); $conf->set('metadata.broker.list', config('kafka')); $conf->set('sasl.username',config('kafka')); $conf->set('sasl.password',config('kafka')); $conf->set('sasl.mechanisms',config('kafka')); $conf->set('security.protocol',config('kafka')); $conf->setRebalanceCb(function (\RdKafka\KafkaConsumer $kafka, $err,...

Hi, We are using low-level consumer for batch processing. Can we identify if any consumer is running which is consuming the messages from that partition? Basically in case of multiple...