java kafka 怎么传输对象
1个回答
2016-02-25 · 知道合伙人互联网行家
护肤达人IT宅族
知道合伙人互联网行家
采纳数：5637
获赞数：17441
毕业于曲阜师范大学，学士学位。互联网行业2年从业经验，读过SEO相关书籍。现任爱家网SEO优化专员。
向TA提问 私信TA
关注
![]()
展开全部
1.zookeeper集群 搭建在110， 111,112
2.kafka使用3个节点110， 111,112
修改配置文件config/server.properties
broker.id=110
host.name=192.168.1.110
log.dirs=/usr/local/kafka_2.10-0.8.2.0/logs
复制到其他两个节点，然后修改对应节点上的config/server.pro
3.启动,在三个节点分别执行
bin/kafka-server-start.sh config/server.properties >/dev/null 2>&1 &
4 创建主题
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 3 --partitions 3 --topic test
5 查看主题详细
bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic test
--topic test
Topic:test PartitionCount:3 ReplicationFactor:3 Configs:
Topic: test Partition: 0 Leader: 110 Replicas: 110,111,112 Isr: 110,111,112
Topic: test Partition: 1 Leader: 111 Replicas: 111,112,110 Isr: 111,112,110
Topic: test Partition: 2 Leader: 112 Replicas: 112,110,111 Isr: 112,110,111
2.kafka使用3个节点110， 111,112
修改配置文件config/server.properties
broker.id=110
host.name=192.168.1.110
log.dirs=/usr/local/kafka_2.10-0.8.2.0/logs
复制到其他两个节点，然后修改对应节点上的config/server.pro
3.启动,在三个节点分别执行
bin/kafka-server-start.sh config/server.properties >/dev/null 2>&1 &
4 创建主题
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 3 --partitions 3 --topic test
5 查看主题详细
bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic test
--topic test
Topic:test PartitionCount:3 ReplicationFactor:3 Configs:
Topic: test Partition: 0 Leader: 110 Replicas: 110,111,112 Isr: 110,111,112
Topic: test Partition: 1 Leader: 111 Replicas: 111,112,110 Isr: 111,112,110
Topic: test Partition: 2 Leader: 112 Replicas: 112,110,111 Isr: 112,110,111
已赞过
已踩过<
评论
收起
你对这个回答的评价是？
推荐律师服务：
若未解决您的问题，请您详细描述您的问题，通过百度律临进行免费专业咨询
