Kafka学习

结构

分为消费者 Croducer 主题 Topic 生产者 Producer
其中Topic包括

Topic中包括了分区和offset偏移量的概念；

一个简单的Kafka发消息收消息java代码：
消费者：

@Component
public class EventConsumer {
   @Resource
   private KafkaTemplate<String,String> kafkaTemplate;

   // 采用监听得方式接收
   @KafkaListener(topics = {"test"},groupId = "hello")
   public void onEvent(String event){
       System.out.println("读取到了时间消息: " + event);
   }
}
1
2
3
4
5
6
7
8
9
10
11

生产者

@Component
public class EventProducer {
    @Resource
    private KafkaTemplate<String,String> kafkaTemplate;

    // 消息发送
    public void sendEvent(String message){
        kafkaTemplate.send("test",message);
    } 
}
1
2
3
4
5
6
7
8
9
10

消费者偏移量的设置

发送消息的一些方法

// 消息发送
public void sendEvent(String message){
   kafkaTemplate.send("test",message);
}

// 发送message对象
public void sendEvent2(String message){
   // 创建message对象
   Message<String> kafka = MessageBuilder.withPayload(message)
           // 设置topic
           .setHeader(KafkaHeaders.TOPIC,"test")
           .build();
   kafkaTemplate.send(kafka);
}

public void sendEvent3(String message){
   // 消费者可以从Headers中取到信息.
   Headers headers = new RecordHeaders();
   headers.add("orderId","123".getBytes(StandardCharsets.UTF_8));
   ProducerRecord<String,String> record = new ProducerRecord<>(
           "test",
           0,
           System.currentTimeMillis(),
           "k1",
           message,
           headers);
   kafkaTemplate.send(record);
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28