Python을 이용한 컨슈머 코드
Python을 이용한 컨슈머 코드 from kafka import KafkaConsumer #(1) consumer = KafkaConsumer('peter-topic',group_id='peter-consumer', bootstrap_servers='kafka01:9092,kafka02:9092',enable_auto_commit=True, auto_offset_reset='latest') #(2) for message in consumer: print "Topic: %s, Partition: %d, Offset: %d, Key: %s, Value: %s" % ( message.topic, message.partition, message.offset, message.key, message.value. ..