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

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

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