Làm cách nào để thêm nhóm người tiêu dùng vào thư trong java?

Question

Tôi mới trong java, mùa xuân và Kafka
Tôi có đoạn code sau để gửi thông điệp

kafkaTemplate.send(topic, message); 

cấu hình của tôi cho sản xuất:

props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, 
      bootstrapServers); 
    props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, 
      IntegerSerializer.class); 
    props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, 
      StringSerializer.class); 
    // value to block, after which it will throw a TimeoutException 
    props.put(ProducerConfig.MAX_BLOCK_MS_CONFIG, 5000); 

Tôi muốn gửi thông điệp với nhóm người tiêu dùng của tôi (ví dụ "MyConsumerGroup"),
nhưng tôi không biết làm thế nào tôi có thể làm điều đó cảm ơn sự giúp đỡ

Answer 1

Khái niệm "nhóm người tiêu dùng" chỉ áp dụng cho người tiêu dùng (như tên đề xuất). Nếu bạn viết một tin nhắn cho Kafka, bất kỳ nhóm người tiêu dùng nào cũng có thể đọc tin nhắn sau này.

Vì vậy, nếu bạn viết một thông điệp, việc xác định một nhóm người tiêu dùng là không thể vì nó sẽ không có ý nghĩa gì cả.