springboot项目配置多个kafka的示例代码

下面是关于springboot项目配置多个kafka的攻略。

配置pom.xml文件

首先，在pom.xml文件中添加kafka和spring-kafka的依赖：

<dependency>
    <groupId>org.springframework.kafka</groupId>
    <artifactId>spring-kafka</artifactId>
    <version>2.5.0.RELEASE</version>
</dependency>

<dependency>
    <groupId>org.apache.kafka</groupId>
    <artifactId>kafka-clients</artifactId>
    <version>2.6.0</version>
</dependency>

配置application.yml文件

接着，在application.yml文件中添加多个kafka的配置，例如：

# kafka1
spring.kafka.producer.bootstrap-servers: localhost:9092
spring.kafka.producer.key-serializer: org.apache.kafka.common.serialization.StringSerializer
spring.kafka.producer.value-serializer: org.apache.kafka.common.serialization.StringSerializer
spring.kafka.consumer.bootstrap-servers: localhost:9092
spring.kafka.consumer.group-id: group-1
spring.kafka.consumer.key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
spring.kafka.consumer.value-deserializer: org.apache.kafka.common.serialization.StringDeserializer

# kafka2
spring.kafka2.producer.bootstrap-servers: localhost:9093
spring.kafka2.producer.key-serializer: org.apache.kafka.common.serialization.StringSerializer
spring.kafka2.producer.value-serializer: org.apache.kafka.common.serialization.StringSerializer
spring.kafka2.consumer.bootstrap-servers: localhost:9093
spring.kafka2.consumer.group-id: group-2
spring.kafka2.consumer.key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
spring.kafka2.consumer.value-deserializer: org.apache.kafka.common.serialization.StringDeserializer

编写示例代码

最后，便可以编写示例代码。这里提供两个示例：

示例一

下面是一个发送消息到多个kafka集群的示例代码：

@Service
public class KafkaProducerService {

    @Autowired
    @Qualifier("kafkaTemplate1")
    private KafkaTemplate<String, Object> kafkaTemplate1;

    @Autowired
    @Qualifier("kafkaTemplate2")
    private KafkaTemplate<String, Object> kafkaTemplate2;

    public void sendMessage(String message) {
        kafkaTemplate1.send("topic1", message);
        kafkaTemplate2.send("topic2", message);
    }
}

示例二

下面是一个从多个kafka集群中获取消息的示例代码：

@Service
public class KafkaConsumerService {

    @KafkaListener(topics = "topic1", groupId = "group-1")
    public void receiveMessageFromKafka1(String message) {
        System.out.println("Received message from kafka1: " + message);
    }

    @KafkaListener(topics = "topic2", groupId = "group-2")
    public void receiveMessageFromKafka2(String message) {
        System.out.println("Received message from kafka2: " + message);
    }
}

总结

以上就是配置springboot项目多个kafka集群的攻略以及两条示例代码。在配置过程中，需要注意多个kafka集群的配置内容，以及在代码中指定使用的kafkaTemplate和消费者监听的topic和groupId。