Java获取指定topic每个分区的当前偏移量
本文介绍了如何使用Java获取指定topic每个分区的当前偏移量。首先通过在pom.xml中引入spring-kafka的依赖，然后在properties文件中配置消费者信息。接着通过编写KafkaU...
标签： kafka
多topic注入kafka消费者
本文介绍了在Kafka消费者中注入多个topic的两种方式。第一种方式是通过EL表达式在`@KafkaListener`注解中直接加载多个topic，通过`application.properties...
基于SpringKafka构建客户端
基于SpringKafka构建的客户端代码使用了spring-kafka库，通过配置KafkaConfig类实现了对Kafka生产者的一系列参数设置，包括缓存容量、控制握手次数等。KafkaServi...
