-
查看和重置Kafka消费进度 - 分布式消息服务Kafka版
/kafka-consumer-groups.sh --bootstrap-server {broker_ip}:{port} --offsets --describe --all-groups 已开启密文接入的Kafka实例,通过以下步骤查询消费进度。 (可选)如果已经设置了用户名和密码,以及SS
-
修改Kafka Topic配置 - 分布式消息服务Kafka版
开启:生产的每条消息都会立即写入磁盘,可靠性更高。 关闭:生产的消息存在内存中,不会立即写入磁盘。 消息时间戳类型 定义消息中的时间戳类型,取值如下: CreateTime:生产者创建消息的时间。 LogAppendTime:broker将消息写入日志的时间。 批处理消息最大值 Kafka允许
-
优化消费者轮询(Polling) - 分布式消息服务Kafka版
ConsumerRecord<String, String> cr = iter.next(); System.out.println("Thread" + workerId + " recievedrecords" + cr.value());
-
Kafka客户端使用建议 - 分布式消息服务Kafka版
自动创建此Topic,此Topic的默认参数值如下:分区数为3,副本数为3,老化时间为72小时,不开启同步复制和同步落盘,消息时间戳类型为CreateTime,批处理消息最大值为10485760字节。 其他建议 连接数限制:3000 消息大小:不能超过10MB 使用SASL_SS
-
状态码 - 分布式消息服务Kafka版
Switching Protocols 切换协议。只能切换到更高级的协议。 例如,切换到HTTP的新版本协议。 200 OK 请求成功。 201 Created 创建类的请求完全成功。 202 Accepted 已经接受请求,但未处理完成。 203 Non-Authoritative Information
-
制作和替换Kafka的SSL证书 - 分布式消息服务Kafka版
-CAkey ca-key -in server.cert-file -out server.cert-signed -days 3650 -CAcreateserial 按照提示信息输入2中设置的PEM密码。 将CA证书导入到服务器keystore。 keytool -keystore
-
配置Kafka间的数据复制 - 分布式消息服务Kafka版
PLAINTEXT:表示实例未开启认证。 认证机制 “认证方式”为“SASL_SSL”/“SASL_PLAINTEXT”时,需要设置。 SCRAM-SHA-512:采用哈希算法对用户名与密码生成凭证,进行身份校验的安全认证机制,比PLAIN机制安全性更高。 PLAIN:一种简单的用户名密码校验机制。
-
创建Kafka实例 - 分布式消息服务Kafka版
是否必选 说明 name String 是 实例名称。 由英文字符开头,只能由英文字母、数字、中划线、下划线组成,长度为4~64的字符。 description String 否 实例的描述信息。 长度不超过1024的字符串。 说明: \与"在json报文中属于特殊字符,如果参数值中需