tianyunperfect/python-base--: python各种demo utils @ 7ded6b5ad2701c88a19768f674a133ebc10b65d7 - Gogs

tianyun 31083d7011 1		před 1 rokem
..
AKafkaPushTest.py	723b35a73e 添加kafka、es demo	před 3 roky
KafkaPush.py	840a0fcee0 Changes	před 2 roky
KafkaPushTest.py	31083d7011 1	před 1 rokem
KafkaPushTest11.py	ed2612040a Changes	před 2 roky
Readme.md	840a0fcee0 Changes	před 2 roky
kafkaReceive.py	190c6a791a Changes	před 2 roky
kafkaReceiveTest.py	31083d7011 1	před 1 rokem
kafkaReceiveTest1.py	840a0fcee0 Changes	před 2 roky
kafkaReceiveTest11.py	ed2612040a Changes	před 2 roky
kafka_topic.py	9e58ab5057 Changes	před 2 roky

接收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好"}' ```