新都在

本文介绍了如何使用Java获取指定topic每个分区的当前偏移量。首先通过在pom.xml中引入spring-kafka的依赖，然后在properties文件中配置消费者信息。接着通过编写KafkaUtil工具类中的方法，可以获取指定topic下每个分区的偏移量信息。最后，在主程序中传入需要获取偏移量的topic集合和配置信息，调用KafkaUtil方法即可实现获取每个分区的当前偏移量。同时，作者提供了properties文件自动注入的方式加载配置信息。

本文介绍了在Kafka消费者中注入多个topic的两种方式。第一种方式是通过EL表达式在`@KafkaListener`注解中直接加载多个topic，通过`application.properties`配置文件指定topic列表。第二种方式是通过解析数据生成对象进行注入，通过自定义`KafkaListenerConfig`类实现`BeanDefinitionRegistryPostProcessor`接口，在该类中读取配置文件中的topic列表，并注册成Bean，然后在消费对象`KafkaListenerReceiver`中使用`@KafkaListener`注解加载多个topic。通过这两种方式，实现了在Kafka消费者中注入多个topic的灵活性和可扩展性。

基于SpringKafka构建的客户端代码使用了spring-kafka库，通过配置KafkaConfig类实现了对Kafka生产者的一系列参数设置，包括缓存容量、控制握手次数等。KafkaService接口定义了发送数据到指定topic、检验topic是否存在以及创建指定topic的方法。KafkaServiceImpl则实现了这些方法，通过KafkaAdmin和KafkaTemplate完成对Kafka的操作，包括发送数据、校验topic是否存在以及创建topic。整体实现了对Kafka客户端的便捷操作，提高了代码的可读性和易用性。