首页
文章
爱发电
我的
图库
留言板
友情链接
我的动态
关于
资讯服务
摸鱼日报
内涵段子
明星吃瓜
新闻头条
本站资源
常用工具汇总
咸鱼大卖场
小说阅读器
爱发电商店
爱盼搜索
自动证书服务
站点统计
对象云存储
代码仓库(自用不开放)
图床服务(自用不开放)
Alist网盘(自用不开放)
Emby服务(自用不开放)
主题展示
新都在
行动起来,活在当下
累计撰写
176
篇文章
累计创建
38
个标签
累计收到
94
条评论
栏目
首页
文章
爱发电
我的
图库
留言板
友情链接
我的动态
关于
资讯服务
摸鱼日报
内涵段子
明星吃瓜
新闻头条
本站资源
常用工具汇总
咸鱼大卖场
小说阅读器
爱发电商店
爱盼搜索
自动证书服务
站点统计
对象云存储
代码仓库(自用不开放)
图床服务(自用不开放)
Alist网盘(自用不开放)
Emby服务(自用不开放)
主题展示
目 录
CONTENT
kafka-新都在
以下是
kafka
相关的文章
2023-02-02
Java获取指定topic每个分区的当前偏移量
本文介绍了如何使用Java获取指定topic每个分区的当前偏移量。首先通过在pom.xml中引入spring-kafka的依赖,然后在properties文件中配置消费者信息。接着通过编写KafkaUtil工具类中的方法,可以获取指定topic下每个分区的偏移量信息。最后,在主程序中传入需要获取偏移量的topic集合和配置信息,调用KafkaUtil方法即可实现获取每个分区的当前偏移量。同时,作者提供了properties文件自动注入的方式加载配置信息。
2023-02-02
26
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
88
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
30
0
0
后端