0
点赞
收藏
分享

微信扫一扫

Python与ArcGIS系列(三)视图缩放

SDKB英文 2023-11-13 阅读 51

@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

举报

相关推荐

0 条评论