Skip to content

Latest commit

 

History

History
15 lines (13 loc) · 522 Bytes

README.md

File metadata and controls

15 lines (13 loc) · 522 Bytes

Kafka-Multi-Process

配置VM Option

-Dtsf_consul_ip=127.0.0.1 -Dtsf_consul_port=8500

配置kafka环境

zookeeper-server-start config/zookeeper.properties &  
kafka-server-start config/server.properties &
kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 4 --topic kafka-multi
javac -cp "/usr/local/Cellar/kafka/1.1.0/libexec/libs/*" ConsumerTest.java
java -classpath  /usr/local/Cellar/kafka/1.1.0/libexec/libs/*:. ConsumerTest kafka-multi my-group