Step 1: 启动服务器

首先启动zookeeper

bin/zookeeper-server-start.sh config/zookeeper.properties

(远程启动的时候需要在后面加上一个 & 作为后台进程,然后断开和远程的链接)

bin/zookeeper-server-start.sh config/zookeeper.properties &

接着启动kafka服务器

bin/kafka-server-start.sh config/server.properties &

Step 2: 创建 一个 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

Step 3: Send some messages

bin/kafka-console-producer.sh –broker-list localhost:9092 –topic test
This is a message
This is another message

Step 4: 启动一个客户端(消费者)

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

参考:http://www.cnblogs.com/qingyuuu/p/5844790.html
http://blog.csdn.net/tangdong3415/article/details/53432166

Logo

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

更多推荐