@KafkaListener 注解提供了许多可配置的参数,以便更灵活地定制 Kafka 消息监听器的行为。
topics:
groupId:
id:
concurrency:
containerFactory:
autoStartup:
clientIdPrefix:
containerGroup:
errorHandler:
properties:
这些参数可以根据实际需求进行组合和配置,以满足特定场景的要求。例如,通过调整 concurrency 可以控制监听器的并发性,通过设置 autoStartup 可以控制监听器容器是否在应用启动时自动启动。其他参数也可以根据需要进行调整。
DEMO
import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Service;
@Service
public class KafkaConsumerService {
@KafkaListener(topics = "my-topic", groupId = "my-group")
public void listen(ConsumerRecord<String, String> record) {
System.out.println("Received message: " + record.value());
}
}
关于ConsumerRecord<?, ?> record的介绍参考:url
@KafkaListener注解应用于listen方法,指定要监听的Kafka主题和消费者组ID。
在application.properties中配置Kafka连接信息:
spring.kafka.bootstrap-servers=localhost:9092
spring.kafka.consumer.group-id=my-group
关于kafka在application.properties配置参数的介绍参考:url