tianyunperfect 190c6a791a Changes 2 tahun lalu
..
AKafkaPushTest.py 723b35a73e 添加kafka、es demo 3 tahun lalu
KafkaPush.py 840a0fcee0 Changes 2 tahun lalu
KafkaPushTest.py 723b35a73e 添加kafka、es demo 3 tahun lalu
KafkaPushTest11.py ed2612040a Changes 2 tahun lalu
Readme.md 840a0fcee0 Changes 2 tahun lalu
kafkaReceive.py 190c6a791a Changes 2 tahun lalu
kafkaReceiveTest.py 840a0fcee0 Changes 2 tahun lalu
kafkaReceiveTest1.py 840a0fcee0 Changes 2 tahun lalu
kafkaReceiveTest11.py ed2612040a Changes 2 tahun lalu
kafka_topic.py 9e58ab5057 Changes 2 tahun lalu

Readme.md

  • 接收topic消息

    python3 ~/IdeaProjects/python-base/tmp/kafka/kafkaReceive.py \
    kafka-0.kafka-headless.rxdpdev.svc.k5.bigtree.zone:9092,kafka-1.kafka-headless.rxdpdev.svc.k5.bigtree.zone:9092,kafka-2.kafka-headless.rxdpdev.svc.k5.bigtree.zone:9092 \
    tag_flag_topic
    
    • 发送topic消息 ```shell python3 ~/IdeaProjects/python-base/tmp/kafka/KafkaPush.py \ kafka-0.kafka-headless.rxdpdev.svc.k5.bigtree.zone:9092,kafka-1.kafka-headless.rxdpdev.svc.k5.bigtree.zone:9092,kafka-2.kafka-headless.rxdpdev.svc.k5.bigtree.zone:9092 \ tag_flag_topic \ 你好啊

    python3 ~/IdeaProjects/python-base/tmp/kafka/KafkaPush.py \ kafka-0.kafka-headless.rxdpdev.svc.k5.bigtree.zone:9092,kafka-1.kafka-headless.rxdpdev.svc.k5.bigtree.zone:9092,kafka-2.kafka-headless.rxdpdev.svc.k5.bigtree.zone:9092 \ tag_flag_topic \ '{"a":"b好"}' ```