技术文摘
Kafka Java客户端代码范例
Kafka Java客户端代码范例
在当今大数据和分布式系统的时代,Kafka作为一种高性能、分布式的消息队列系统,被广泛应用于各种场景。本文将为你提供一个简单的Kafka Java客户端代码范例,帮助你快速上手Kafka。
确保你已经安装并配置好了Kafka环境。在Java项目中,需要添加Kafka客户端的依赖。如果使用Maven项目,可以在pom.xml文件中添加以下依赖:
<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka-clients</artifactId>
<version>2.8.0</version>
</dependency>
接下来,我们来看生产者代码示例。生产者负责向Kafka主题发送消息:
import org.apache.kafka.clients.producer.*;
import java.util.Properties;
public class KafkaProducerExample {
public static void main(String[] args) {
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);
ProducerRecord<String, String> record = new ProducerRecord<>("my-topic", "key", "Hello, Kafka!");
producer.send(record);
producer.close();
}
}
上述代码中,我们配置了Kafka服务器地址、键和值的序列化器,然后创建了一个生产者实例,发送一条消息到名为“my-topic”的主题中。
再来看消费者代码示例。消费者用于从Kafka主题中接收消息:
import org.apache.kafka.clients.consumer.*;
import java.util.Collections;
import java.util.Properties;
public class KafkaConsumerExample {
public static void main(String[] args) {
Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("group.id", "my-group");
props.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
props.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
Consumer<String, String> consumer = new KafkaConsumer<>(props);
consumer.subscribe(Collections.singletonList("my-topic"));
while (true) {
ConsumerRecords<String, String> records = consumer.poll(100);
for (ConsumerRecord<String, String> record : records) {
System.out.println("Received message: " + record.value());
}
}
}
}
这里配置了消费者相关属性,订阅了“my-topic”主题,并不断轮询获取消息并打印。
通过上述代码范例,你可以初步了解Kafka Java客户端的基本使用,为进一步深入学习和应用打下基础。
TAGS: Kafka Java客户端 代码范例 Kafka Java
- MySQL 与 Java 实现简单文件下载功能的方法
- Redis 与 Julia 语言助力实现高可用集群功能的方法
- Python在MySQL中编写自定义触发器的方法
- Redis 与 Perl 6 助力开发分布式任务调度功能的方法
- MySQL 与 Go 语言打造简易日程提醒系统的方法
- D语言与Redis结合开发分布式共享内存功能的方法
- MySQL与Java实现简单数据清洗功能的方法
- MySQL与C++ 实现简单图片水印功能开发方法
- PHP编写MySQL自定义触发器与存储过程的方法
- MySQL与Python助力开发简单在线调查问卷的方法
- Redis与Groovy助力开发实时推荐功能的方法
- Redis 与 TypeScript 助力开发高性能计算功能的方法
- Rust语言结合Redis实现异步任务队列功能的方法
- MySQL与Java助力开发简易在线购物系统的方法
- Python在MySQL中编写自定义存储过程与函数的方法