mirror of
https://github.com/newnius/YAO-agent.git
synced 2025-06-02 20:01:55 +00:00
bin | ||
.gitignore | ||
agent.py | ||
executor.py | ||
LICENSE | ||
mock.py | ||
monitor.py | ||
README.md | ||
test.py |
YAO-agent
https://docker-py.readthedocs.io/en/stable/containers.html
bin/kafka-topics.sh \
--create \
--zookeeper zookeeper-node1:2181,zookeeper-node2:2181,zookeeper-node3:2181 \
--replication-factor 3 \
--partitions 6 \
--topic yao
bin/kafka-topics.sh \
--describe \
--zookeeper zookeeper-node1:2181,zookeeper-node2:2181,zookeeper-node3:2181 \
--topic yao
bin/kafka-console-consumer.sh \
--bootstrap-server kafka-node1:9092,kafka-node2:9092,kafka-node3:9092 \
--topic yao \
--from-beginning
bin/kafka-console-producer.sh \
--broker-list kafka-node1:9092,kafka-node2:9092,kafka-node3:9092 \
--topic yao
bin/kafka-topics.sh \
--delete \
--zookeeper zookeeper-node1:2181,zookeeper-node2:2181,zookeeper-node3:2181 \
--topic yao