1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39
| tar -xvf kafka_2.11-2.2.2.tgz mv kafka_2.11-2.2.2 /usr/local/kafka
vi /usr/local/kafka/config/server.properties
broker.id=0 num.network.threads=3 num.io.threads=8 socket.send.buffer.bytes=102400 socket.receive.buffer.bytes=102400 socket.request.max.bytes=104857600 log.dirs=/usr/local/kafka/logs num.partitions=3 num.recovery.threads.per.data.dir=1 offsets.topic.replication.factor=1 transaction.state.log.replication.factor=1 transaction.state.log.min.isr=1 log.retention.hours=60 log.segment.bytes=1073741824 log.retention.check.interval.ms=300000 zookeeper.connect=192.168.8.225:2181,192.168.8.226:2181,192.168.8.227:2181 zookeeper.connection.timeout.ms=6000 group.initial.rebalance.delay.ms=0
nohup /usr/local/kafka/bin/kafka-server-start.sh /usr/local/kafka/config/server.properties 1>kafka.log 2>&1 & tail -f kafka.log
bin/kafka-topics.sh --zookeeper 192.168.8.225:2181,192.168.8.226:2181,192.168.8.227:2181 --list
bin/kafka-topics.sh --zookeeper 192.168.8.225:2181,192.168.8.226:2181,192.168.8.227:2181 --create --topic elktopic \ > --partitions 3 --replication-factor 1
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic elktopic --from-beginning
|