Skip to content

Latest commit

 

History

History
23 lines (16 loc) · 453 Bytes

Kafka.md

File metadata and controls

23 lines (16 loc) · 453 Bytes

Kafka

Producer

address = '{}:{}'.format(kafka_ip,kafka_port)
producer = KafkaProducer(bootstrap_servers=[address],api_version=(0,10,1))

producer.send("topic_name",send_str.encode())

Comsumer

address = '{}:{}'.format(kafka_ip,kafka_port)
consumer = KafkaConsumer('topic_name',bootstrap_servers=[address],api_version=(0, 10))

for message in consumer:
    msg = message.value.decode()
    print('msg:',msg)