技术文摘
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
- IDEA中Redis插件连接Redis服务器的使用方法
- 如何在Docker容器中将Oracle迁移到MySQL
- Golang实现Redis协议解析器的方法
- Redis设置密码不生效怎么解决
- Redis的过期策略是怎样的
- 如何在redis中设置key的有效期
- MySQL锁有哪些及如何分类
- CentOS 7 安装单机环境 Redis 3.2 的方法
- Redis哨兵模式原理如何解析
- 如何解决MySQL字符集编码问题
- MySQL 池化自定义实例深入剖析
- PHP 如何修改 MySQL 数据库中的数据
- MySQL日志中redo log和undo log有哪些知识点
- Oracle与MySQL拼接值的坑及双竖线||与concat使用方法
- Redis漏洞利用示例剖析