wangrui/llpt_migration-kafkaproducer

Không có mô tả

wangrui cbdc8757eb init		1 năm trước cách đây
.mvn	cbdc8757eb init	1 năm trước cách đây
sql	cbdc8757eb init	1 năm trước cách đây
src	cbdc8757eb init	1 năm trước cách đây
.classpath	cbdc8757eb init	1 năm trước cách đây
.gitignore	cbdc8757eb init	1 năm trước cách đây
HELP.md	cbdc8757eb init	1 năm trước cách đây
README.MD	cbdc8757eb init	1 năm trước cách đây
mvnw	cbdc8757eb init	1 năm trước cách đây
mvnw.cmd	cbdc8757eb init	1 năm trước cách đây
pom.xml	cbdc8757eb init	1 năm trước cách đây
代码部署.docx	cbdc8757eb init	1 năm trước cách đây
订购关系同步定时任务.docx	cbdc8757eb init	1 năm trước cách đây

部署服务器 100.0.3.96 路径 /home/kc/project/flowstatus 测试日志地址 /home/kc/project/flowstatus/logs 正式日志路径 /data/logs/flowstatus/kafkaproducer

创建 topic bin/kafka-topics.sh -create --zookeeper 100.0.3.94:2181,100.0.3.95:2181,100.0.3.96:2181 -replication-factor 3 --partitions 3 --topic flowstatustopic_test

修改 topic bin/kafka-topics.sh --alter --zookeeper 100.0.3.94:2181,100.0.3.95:2181,100.0.3.96:2181 --topic 主题名称 --partitions 分区数量

查看 topic bin/kafka-topics.sh --list --zookeeper localhost:2181

bin/kafka-topics.sh --describe --zookeeper 100.0.3.94:2181,100.0.3.95:2181,100.0.3.96:2181 --topic flowstatustopic_test

生产消息 ./bin/kafka-console-producer.sh --broker-list 100.0.3.96:9092 --topic test1 --producer.config ./config/producer.properties

消费 ./bin/kafka-console-consumer.sh --bootstrap-server 100.0.3.96:9092 --topic test1 --from-beginning --consumer.config ./config/consumer.properties

删除topic ./bin/kafka-topics.sh --delete --zookeeper 100.0.3.94:2181,100.0.3.95:2181,100.0.3.96:2181 --topic test

README.MD