天翼云分布式消息服务Kafka环境准备

分布式消息服务Kafka

简介/价格/文档

天翼云分布式消息服务Kafka环境准备

文档简介：

1. 购买Kafka实例 2. 下载安装工具Eclipse3.6.0以上上版本或者IntelliJ ，JDK 1.8.111以上版本。

*产品来源：中国电信天翼云。免费试用咨询热线：400-826-7010，为您提供专业的售前咨询，让您快速了解云产品，助您轻松上云！微信咨询

1. 购买Kafka实例

2. 下载安装工具Eclipse3.6.0以上上版本或者IntelliJ ，JDK 1.8.111以上版本。

相似文档

天翼云分布式消息服务Kafka创建Topic
1. 点击Topic管理后、点击“新建Topic”。 2. 点击“新建Topic”后，出现如下创建，输入Topic名称、分区数、选择是否私密主题。 3. 创建后的Topic出现在列表，可点击“生成拨测”来测试Topic是否正常
天翼云分布式消息服务Kafka创建消费组
1. 点击消费组管理后、点击“新建消费组”。 2. 点击“新建消费组”后，输入消费组名称，点击创建。 3. 创建后的消费组出现在消费组列表，点击“主题订阅”来订阅step2的主题，并且可通过“消费拨测”来测试是否正常消费。
天翼云分布式消息服务Kafka编译运行Demo Java工程
编译运行Demo Java工程 Tips: 需要kafka-clients引入依赖： org.apache.kafka kafka-clients
天翼云分布式消息服务Kafka Java生产者SDK接口
生产者接口 org.apache.kafka.clients.producer.KafkaProducer 1）发送消息，返回值为Future public Future send(ProducerRecord record); public Future send(ProducerRecord record, Callback callback);
天翼云分布式消息服务Kafka Java消费者SDK接口
接口方法概述（1）消费者接口 org.apache.kafka.clients.producer. KafkaConsumer 1）拉取消息，返回值为ConsumerRecords ConsumerRecords poll(long timeout) 创建消费者（1）消费者实例化

文档中心