Python KafkaConsumer not connecting

docker apache-kafka jupyter-notebook kafka-consumer-api kafka-producer-api

By default auto.offset.reset value is latest, so set it to earliest with new group.id

consumer = KafkaConsumer('my-topic',group_id='new-group',auto_offset_reset = 'earliest',bootstrap_servers=KAFKA_BROKER)

CodeHunter