天翼云分布式消息服务Kafka创建消费组

分布式消息服务Kafka

简介/价格/文档

文档简介：

1. 点击消费组管理后、点击“新建消费组”。 2. 点击“新建消费组”后，输入消费组名称，点击创建。 3. 创建后的消费组出现在消费组列表，点击“主题订阅”来订阅step2的主题，并且可通过“消费拨测”来测试是否正常消费。

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

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）消费者实例化
天翼云分布式消息服务Kafka发布者实践
本文主要介绍消息队列 Kafka 发布者的最佳实践，从而帮助您更好的使用该产品。文中的最佳实践基于消息队列 Kafka 的 Java 客户端；对于其它语言的客户端，其基本概念与思想是通用的，但实现细节可能有差异，仅供参考。
天翼云分布式消息服务Kafka消费者实践
Kafka 的消费者示例代码片段如下： Properties properties = new Properties(); properties.put("bootstrap.servers", "192.168.90.139:8090,192.168.90.41:8090,192.168.90.42:8090"); properties.put("group.id", "ppsgroup"); properties.put("enable.auto.commit", "true");

文档中心