kafka-version=3.4
python version=3.9
I can see in server connection is accepted but however I am unable to get msg. msg is there in topics.
below is my python code
from confluent_kafka import Consumer, KafkaError
import logging
logging.basicConfig(level=logging.DEBUG)
conf = {
‘bootstrap.servers’: ‘ip:9092’,
‘group.id’: ‘nsumer89-grokkkup’,
‘enable.auto.commit’: True,
‘auto.offset.reset’: ‘earliest’
}
consumer = Consumer(conf)
consumer.subscribe([‘rk’])
while True:
msg = consumer.poll(1.0)
if msg is None:
continue
if msg.error():
if msg.error().code() == KafkaError._PARTITION_EOF:
print('End of partition reached')
else:
print('Error while consuming message: {}'.format(msg.error()))
else:
print('Received message: {}'.format(msg.value().decode('utf-8')))
I am getting error: %3|1683687673.706|FAIL|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: 192.168.0.15:9092: Connect to ipv4#192.168.0.15:9092 failed: Unknown error (after 21027ms in state CONNECT)