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

tianyun 31083d7011 1		hai 1 ano
..
AKafkaPushTest.py	723b35a73e 添加kafka、es demo	%!s(int64=3) %!d(string=hai) anos
KafkaPush.py	840a0fcee0 Changes	%!s(int64=2) %!d(string=hai) anos
KafkaPushTest.py	31083d7011 1	hai 1 ano
KafkaPushTest11.py	ed2612040a Changes	%!s(int64=2) %!d(string=hai) anos
Readme.md	840a0fcee0 Changes	%!s(int64=2) %!d(string=hai) anos
kafkaReceive.py	190c6a791a Changes	%!s(int64=2) %!d(string=hai) anos
kafkaReceiveTest.py	31083d7011 1	hai 1 ano
kafkaReceiveTest1.py	840a0fcee0 Changes	%!s(int64=2) %!d(string=hai) anos
kafkaReceiveTest11.py	ed2612040a Changes	%!s(int64=2) %!d(string=hai) anos
kafka_topic.py	9e58ab5057 Changes	%!s(int64=2) %!d(string=hai) anos

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