mirror of
https://github.com/newnius/YAO-agent.git
synced 2025-06-06 05:21:55 +00:00
.gitignore | ||
bootstrap.sh | ||
Dockerfile | ||
executor.py | ||
LICENSE | ||
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 1 \
--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