在安装kafka之前,确保你的服务器上面JDK配置正确,最好用1.7的。


下载地址:

       http://kafka.apache.org/downloads.html



下载完成之后执行解压命令:  tar -zxvf kafka_2.10-0.8.1.1.tgz



	启动服务
	      首先启动zookeeper服务
	      bin/zookeeper-server-start.sh config/zookeeper.properties
	      启动Kafka
      bin/kafka-server-start.sh config/server.properties >/dev/null 2>&1 &


查看服务是否启动:




创建topic:


	创建topic
	        创建一个"test"的topic,一个分区一个副本
          bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test


查看主题


	查看主题
	       bin/kafka-topics.sh --list --zookeeper localhost:2181



查看主题详情


	查看主题详情
	        bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic test



创建生产者:

	bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test 



创建消费者:


	bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning







Logo

Kafka开源项目指南提供详尽教程,助开发者掌握其架构、配置和使用,实现高效数据流管理和实时处理。它高性能、可扩展,适合日志收集和实时数据处理,通过持久化保障数据安全,是企业大数据生态系统的核心。

更多推荐