step

155 环境搭建

1.1 资源拷贝

 1 jdk1.8
 2 kafka
 3 kafka-manager

1.2 jvm 配置
  vim /etc/profile.d/java.sh
  
	JAVA_HOME=/usr/local/jdk1.8.0_60
	CLASS_PATH=$JAVA_HOME/lib:$JAVA_HOME/jre/lib
	PATH=$JAVA_HOME/bin:$PATH
	export JAVA_HOME CLASS_PATH PATH
  验证 java javac java -version $JAVA_HOME
1.2 kafka 配置
  zookeeper 
  修改 zookeeper.properties
  创建 myid 文件 创建文件路经 mkdir -p /data/zookeeper
  修改 service.properties 
  设置启动kafka 内存及jvm端口 bin/**.sh
       if [ "x$KAFKA_HEAP_OPTS" = "x" ]; then
    	 export KAFKA_HEAP_OPTS="-Xmx4G -Xms4G"
   	 export JMX_PORT="9999"
	fi
  启动 zookeeper bin/zookeeper-server-start.sh config/zookeeper.properties 
  启动 kafka bin/kafka-server-start.sh config/server.properties

1.3 kafka manager
 修改 kafka-manager.zkhosts="186****:2181"
 修改 启动端口 
1.4 zabbix kafka 端口监控
1.5 logstash 内存
1.6
 
  kafka 命令 测试
创建 topic
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
查看 topic
bin/kafka-topics.sh --list --zookeeper localhost:2181
生产 topic
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
消费 topic
bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning

/bin/kafka-topics.sh --zookeeper localhost:2181 --alter --topic topiclog  --config retention.ms=17280000