创建消费者对象consumer,可以设置具体的配置信息propsProperties props = new Properties();props.put("bootstrap.servers","borker1:9092,broker2:9092");kafkaConsumer<String,String> consumer = new KafkaConsumer<Str...

broker：（kafka的节点，也就是服务器）1.接受来自生产者的消息，为消息设置偏移量，并提交消息到磁盘保存。2.为消费者提供服务，对读取分区的请求作出相应，返回保存到磁盘的消息。Producer：消息生产者，向Broker发送消息的客户端。Consumer：消息消费者，从Broker读取消息的客户端。ConsumerGroup：每个Consumer属于一个特定的Consumer Gro...

“可重入锁”的概念：自己可以再次获取自己的内部锁。比如一个线程获得了某个对象的锁，此时锁还没释放，当再次获取这个对象锁的时候还可以获取。（如果不能获取，就会造成死锁）。可重入锁的例子如下：package com.hanw.testKafka;public class Test1 {public static void main(String[] args) {MyThread t ...