凌夜知惜

package com.lyzx.kafka;import org.apache.kafka.clients.producer.KafkaProducer;import org.apache.kafka.clients.producer.Producer;import org.apache.kafka.clients.producer.ProducerRecord;import org...

1、自定义分区器    1.1 实现org.apache.kafka.clients.producer.Partitioner接口public int partition(String s, Object o, byte[] bytes, Object o1, byte[] bytes1, Cluster cluster)public void close()public void ...

kafka架构图1、消息队列的类型  1.1 点对点        只有一个消费者做消费TopicA，其他消费者不能消费TopicA中的消息  1.2发布订阅    只要订阅了某个Topic的消费者都可以消费该Topic中的数据对于TopicA，可以由多个消费者订阅 也可以由多多个消费者消费，同一个组中的消费者不能重复消费eg:TopicA中有消息  M1 M2 M3...

package com.lyzx.kafka;import org.apache.kafka.clients.consumer.ConsumerRecord;import org.apache.kafka.clients.consumer.ConsumerRecords;import org.apache.kafka.clients.consumer.KafkaConsumer;imp...

cd kafka.xx.xx.x.x/configvim server.propertiesbroker.id=0  为每台机器设置一个idzookeeper.connect=192.168.29.167:2181,192.168.29.168:2181,192.168.29.169:2181启动zookeeper集群bin/zkServer.sh start  开启zookeeper...

kafka中的consumer1、旧版本的consumer api是由scala语言编写，新版本的consumerapi是由java语言编写    新版本的consumer api采用全新的offset管理2、消费者组的概念    消费者使用一个消费者组名标识自己,topic中的每条消息都会分配到某个消费者组的一个消费者实例上    一个消费者组订阅一个topic，每个topic中的pa...