首页
文章
爱发电
留言板
友情链接
主题展示
Pix
Hao
Joe3
Walker
Stellar
Oyiso
Heolink
图库
关于
新都在
行动起来,活在当下
累计撰写
175
篇文章
累计创建
37
个标签
累计收到
88
条评论
栏目
首页
文章
爱发电
留言板
友情链接
主题展示
Pix
Hao
Joe3
Walker
Stellar
Oyiso
Heolink
图库
关于
目 录
CONTENT
kafka-新都在
以下是
kafka
相关的文章
2023-02-02
Java获取指定topic每个分区的当前偏移量
本文介绍了如何使用Java获取指定topic每个分区的当前偏移量。首先通过在pom.xml中引入spring-kafka的依赖,然后在properties文件中配置消费者信息。接着通过编写KafkaUtil工具类中的方法,可以获取指定topic下每个分区的偏移量信息。最后,在主程序中传入需要获取偏移量的topic集合和配置信息,调用KafkaUtil方法即可实现获取每个分区的当前偏移量。同时,作者提供了properties文件自动注入的方式加载配置信息。
2023-02-02
23
0
0
后端
2023-02-02
多topic注入kafka消费者
本文介绍了在Kafka消费者中注入多个topic的两种方式。第一种方式是通过EL表达式在`@KafkaListener`注解中直接加载多个topic,通过`application.properties`配置文件指定topic列表。第二种方式是通过解析数据生成对象进行注入,通过自定义`KafkaListenerConfig`类实现`BeanDefinitionRegistryPostProcessor`接口,在该类中读取配置文件中的topic列表,并注册成Bean,然后在消费对象`KafkaListenerReceiver`中使用`@KafkaListener`注解加载多个topic。通过这两种方式,实现了在Kafka消费者中注入多个topic的灵活性和可扩展性。
2023-02-02
80
0
0
后端
2023-02-02
基于SpringKafka构建客户端
基于SpringKafka构建的客户端代码使用了spring-kafka库,通过配置KafkaConfig类实现了对Kafka生产者的一系列参数设置,包括缓存容量、控制握手次数等。KafkaService接口定义了发送数据到指定topic、检验topic是否存在以及创建指定topic的方法。KafkaServiceImpl则实现了这些方法,通过KafkaAdmin和KafkaTemplate完成对Kafka的操作,包括发送数据、校验topic是否存在以及创建topic。整体实现了对Kafka客户端的便捷操作,提高了代码的可读性和易用性。
2023-02-02
25
0
0
后端