ubuntu16安装kafka及KafkaOffsetMonitor

环境准备

安装java环境

sudo add-apt-repository -y ppa:webupd8team/java
sudo apt-get update
sudo apt-get install oracle-java8-installer -y

测试是否安装成功sudo java -version

安装ZooKeeper

sudo apt-get install zookeeperd

测试是否安装成功netstat -ant | grep :2181

安装kafka

下载Kafka软件包

https://kafka.apache.org/downloads

wget "http://apache.claz.org/kafka/0.10.2.1/kafka_2.10-0.10.2.1.tgz" -O kafka.tgz

解压

sudo tar -xvf kafka.tgz -C /opt/

启动kafka

sudo /opt/kafka_2.10-0.10.2.1/bin/kafka-server-start.sh /opt/kafka_2.10-0.10.2.1/config/server.properties

可以使用nohup的方式。
sudo /opt/kafka_2.10-0.10.2.1/bin/kafka-server-start.sh /opt/kafka_2.10-0.10.2.1/config/server.properties /tmp/kafka.log 2>&1 &

tmux也行

测试kafka

sudo /opt/kafka_2.10-0.10.2.1/bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1  --partitions 1 --topic testing

安装KafkaOffsetMonitor

项目地址 https://github.com/quantifind/KafkaOffsetMonitor/

下载地址 https://github.com/quantifind/KafkaOffsetMonitor/releases/tag/v0.2.1

下载Monitor

wget https://github.com/quantifind/KafkaOffsetMonitor/releases/download/v0.2.1/KafkaOffsetMonitor-assembly-0.2.1.jar

启动Monitor

java -cp KafkaOffsetMonitor-assembly-0.2.1.jar \
 com.quantifind.kafka.offsetapp.OffsetGetterWeb \
 --zk 127.0.0.1:2181 \
 --port 8089 \
 --refresh 10.seconds \
 --retain 1.days

补充

来后看官方网站上的quickstart，kafka自带的zookeeper-server-start.sh也能启动zookeeper
可以修改server.properties来启动多个brorker
bin也有现成的模拟消费者和生产者的命令
消费者要指定 zookeeper的路径,生产者要指定broker的地址

#参考
https://devops.profitbricks.com/tutorials/install-and-configure-apache-kafka-on-ubuntu-1604-1/
https://segmentfault.com/a/1190000007673372
https://kafka.apache.org/quickstart