kafka 3.9 java

### Kafka 3.9 版本 Java 开发指南 对于希望基于 Kafka 3.9 进行 Java 应用程序开发的开发者而言，了解如何配置依赖项以及编写生产者和消费者代码至关重要。Apache 官方提供了详细的文档来指导使用者完成这些操作。 为了集成 Kafka，在项目中应当引入合适的 Maven 或 Gradle 依赖关系。针对特定版本的需求，确保指定 `kafka-clients` 的版本号为 3.9.x[^1]： ```xml <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <version>3.9.0</version> </dependency> ``` 创建消息发送端即生产者的实例时，需设置必要的属性参数，例如连接地址、序列化方式等。下面是一个简单的例子展示如何初始化一个 Kafka 生产者对象并发送一条记录到指定主题上: ```java Properties props = new Properties(); props.put("bootstrap.servers", "localhost:9092"); props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer"); props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer"); Producer<String, String> producer = new KafkaProducer<>(props); producer.send(new ProducerRecord<>("my-topic", "key", "message")); producer.close(); ``` 同样地，构建消息接收端也就是消费者的流程也相对直观。这里给出一段基础代码用于订阅某个主题，并打印接收到的消息内容: ```java Properties props = new Properties(); props.put("bootstrap.servers", "localhost:9092"); props.put("group.id", "test-group"); props.put("enable.auto.commit", "true"); props.put("auto.offset.reset", "earliest"); props.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer"); props.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer"); KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props); consumer.subscribe(Collections.singletonList("my-topic")); while (true) { ConsumerRecords<String, String> records = consumer.poll(Duration.ofMillis(100)); for (ConsumerRecord<String, String> record : records) System.out.printf("offset = %d, key = %s, value = %s%n", record.offset(), record.key(), record.value()); } ``` 除了官方提供的资源外，网络上有许多第三方博客文章和技术论坛帖子可以作为补充学习材料。不过需要注意的是，当查阅非官方渠道的信息源时要特别留意其时效性和准确性，优先参考最新发布的权威资料。