kafka环境搭建及librdkafka测试
2016-08-05 15:29
435 查看
kafka环境搭建及librdkafka测试
![](http://simg.sinajs.cn/blog7style/images/common/sg_trans.gif)
(2016-04-05 10:18:25)
一、kafka环境搭建(转自http://kafka.apache.org/documentation.html#gettingStarted)
Step 1: Download the code
Download the 0.9.0.0 release and un-tar it.> tar -xzf kafka_2.11-0.9.0.0.tgz > cd kafka_2.11-0.9.0.0
Step 2: Start the server
Kafka uses ZooKeeper so you need to first start a ZooKeeper server if you don't already have one. You can use the convenience script packaged with kafka to get a quick-and-dirty single-node ZooKeeper instance.> bin/zookeeper-server-start.sh config/zookeeper.properties [2013-04-22 15:01:37,495] INFO Reading configuration from:config/zookeeper.properties (org.apache.zookeeper.server.quorum.QuorumPeerConfig) ...
Now start the Kafka server:
> bin/kafka-server-start.sh config/server.properties [2013-04-22 15:01:47,028] INFO Verifying properties (kafka.utils.VerifiableProperties) [2013-04-22 15:01:47,051] INFO Property socket.send.buffer.bytes is overridden to 1048576 (kafka.utils.VerifiableProperties) ...
Step 3: Create a topic
Let's create a topic named "test" with a single partition and only one replica:> bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
We can now see that topic if we run the list topic command:
> bin/kafka-topics.sh --list --zookeeper localhost:2181 test
Alternatively, instead of manually creating topics you can also configure your brokers to auto-create topics when a non-existent topic is published to.
Step 4: Send some messages
Kafka comes with a command line client that will take input from a file or from standard input and send it out as messages to the Kafka cluster. By default each line will be sent as a separate message.Run the producer and then type a few messages into the console to send to the server.
> bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test This is a message This is another message
Step 5: Start a consumer
Kafka also has a command line consumer that will dump out messages to standard output.> bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning This is a message This is another message
If you have each of the above commands running in a different terminal then you should now be able to type messages into the producer terminal and see them appear in the consumer terminal.
All of the command line tools have additional options; running the command with no arguments will display usage information documenting them in more detail.
二、kafka环境配置(若省略此步,其他主机上的客户端访问时会报错)
修改 conf/server.properties
zookeeper.connect=192.168.197.170:2181,192.168.197.171:2181,192.168.197.172:2181(换成你自己的IP)
broker.id分别改成
broker.id=170
broker.id=171
broker.id=172
host.name分别改成(如果不改,client访问集群时,如果没在hosts配置对应机器的 hostname,访问将会报错)
host.name=192.168.197.170(换成你自己的IP)
host.name=192.168.197.171
host.name=192.168.197.172
可根据需求修改
port: broker节点使用端口号 默认 9092
log.dir: 消息目录位置
3,执行librdkafka的例程
修改kafka的配置文件后再重启kafka服务以及消费者程序
此时在客户端主机执行
examples/rdkafka_example -P -b 128.1.0.149:9092 -t test (128.1.0.149换成你自己的IP)
后,会在服务端的消费者执行窗口看到客户端你输入的字符
对于初学者可能参数都不知道该怎么加,可以通过三个地方学习
a,第一步中的kafka生产者测试实例,
b,第三步中的librdkafka生产者实例,
c,执行rdkafka_example时不加参数会提示帮助。
最重要的一点还是要了解kafka的框架。
相关文章推荐
- kmp 算法演示
- Monkey测试简介[附示例]
- Bootstrap 3 布局
- Android BLE蓝牙4.0开发详解
- Jquery的单选框选中
- in与exists
- bindService失败的解决办法
- Python中的打开文件对话框
- vxWorks下,telnet客户端以及pty设备驱动
- 【leetcode】Insert Delete GetRandom O(1)
- #ifdef __cplusplus extern "C" { #endif //一段代码 #ifdef __cplusplus } #endif
- SE新手游操控创新:一个按键=五个技能
- ios时间戳13位转换
- 第三方集成的坑如:java.util.zip.ZipException: duplicate entry: com/ta/utdid2/android/utils/AESUtils.class
- C++11 thread_local 关键词
- Hadoop MapReduce 二次排序
- CSS引用方式
- Ubuntu 中github的配置和使用
- 最详细的Log4j使用教程
- get和post区别