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

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

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