Kafka中数据的流向

1: 多个消费者消费同一个Topic数据相同的数据

（1）使用一个全新的"group.id"（就是之前没有被任何消费者使用过）; （2）使用assign来订阅； # 例如 groupId @KafkaListener(topics = "test-syn",groupId = "test-2") public void send(ConsumerRecord<?, ?> record) { Optional<?> kafkaMessage = Optional.ofNullable(record.value()); if (kafkaMessage.isPresent()) { Object messge = kafkaMessage.get(); log.info("【KafkaListener监听到消息】" + messge); } }