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

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

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