首页
文章
爱发电
留言板
友情链接
图库
关于
新·都在
行动起来,活在当下
累计撰写
168
篇文章
累计创建
32
个标签
累计收到
67
条评论
栏目
首页
文章
爱发电
留言板
友情链接
图库
关于
目 录
CONTENT
kafka-新·都在
以下是
kafka
相关的文章
2023-02-02
Java获取指定topic每个分区的当前偏移量
本文介绍了如何使用Java获取指定topic每个分区的当前偏移量。首先通过在pom.xml中引入spring-kafka的依赖,然后在properties文件中配置消费者信息。接着通过编写KafkaUtil工具类中的方法,可以获取指定topic下每个分区的偏移量信息。最后,在主程序中传入需要获取偏移量的topic集合和配置信息,调用KafkaUtil方法即可实现获取每个分区的当前偏移量。同时,作者提供了properties文件自动注入的方式加载配置信息。
2023-02-02
9
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
29
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
10
0
0
后端