kafka

broker.id=1
port=9092
host.name=192.168.55.91
num.network.threads=2
num.io.threads=8
socket.send.buffer.bytes=1048576
socket.receive.buffer.bytes=1048576
socket.request.max.bytes=104857600
log.dirs=/ddhome/bin/kafka/tmp/kafka-logs
num.partitions=2
log.retention.hours=168
log.segment.bytes=536870912
log.retention.check.interval.ms=60000
log.cleaner.enable=false
zookeeper.connect=192.168.55.91:2181,192.168.55.81:2181,192.168.55.31:2181
zookeeper.connection.timeout.ms=1000000

#kafka\u5B9E\u9645\u4F7F\u7528\u6848\u4F8B 210\u670D\u52A1\u5668kafka\u914D\u7F6E

broker.id=2
port=9092
host.name=192.168.55.81
num.network.threads=2
num.io.threads=8
socket.send.buffer.bytes=1048576
socket.receive.buffer.bytes=1048576
socket.request.max.bytes=104857600
log.dirs=/ddhome/bin/kafka/tmp/kafka-logs
num.partitions=2
log.retention.hours=168
log.segment.bytes=536870912
log.retention.check.interval.ms=60000
log.cleaner.enable=false
zookeeper.connect=192.168.55.91:2181,192.168.55.81:2181,192.168.55.31:2181

zookeeper.connection.timeout.ms=1000000

ssh ddava /ddhome/bin/kafka/bin/kafka-server-start.sh -daemon /ddhome/bin/kafka/config/server.properties &

ssh ddbva /ddhome/bin/kafka/bin/kafka-server-start.sh -daemon /ddhome/bin/kafka/config/server.properties &

kafka-topics.sh --create --zookeeper 192.168.55.91:2181,192.168.55.81:2181,192.168.55.31:2181 --replication-factor1 --partitions1 --topic lhg

kafka-topics.sh --list --zookeeper 192.168.55.91:2181,192.168.55.81:2181,192.168.55.31:2181

kafka-topics.sh --describe --zookeeper 192.168.55.91:2181,192.168.55.81:2181,192.168.55.31:2181 --topic test

kafka-topics.sh --create --zookeeper 192.168.55.91:2181,192.168.55.81:2181,192.168.55.31:2181 --replication-factor 1 --partitions 1 --topic test

kafka-console-producer.sh  --zookeeper 192.168.55.91:2181,192.168.55.81:2181,192.168.55.31:2181 --topic test

kafka-console-consumer.sh --zookeeper 192.168.55.91:2181,192.168.55.81:2181,192.168.55.31:2181 --topic test --from-beginning