Description Parameters Script Example Description Data source for kafka 0.10 Parameters Name Description Type Required？ Default Value bootstrapServers kafka b...

Binlog Slave Client 用户文档 配置 Kafka Drainer 自定义开发 数据格式 Driver Binlog Slave Client 用户文档 目前 Drainer 提供了多种输出方式，包括 MySQL、TiDB、file 等。但是用户往往有一些自定义的需求，比如输出到 Elasticsearch、Hive 等，这些...

通过 Kafka 消息触发诊断 开始之前 在 KubeDiag Master 参数中指定需要消费的 Kafka 和 Topic Kafka 消息格式 举例说明 通过 Kafka 消息触发诊断 通过 Kafka 消息创建 Diagnosis 来触发诊断。 本文介绍了如何通过 Kafka 消息创建 Diagnosis 来触发诊断。 开始之前 ...

Binlog Consumer Client 用户文档 配置 Kafka Drainer 自定义开发 数据格式 Driver Binlog Consumer Client 用户文档 目前 Drainer 提供了多种输出方式，包括 MySQL、TiDB、file 等。但是用户往往有一些自定义的需求，比如输出到 Elasticsearch、Hive...

桥接数据到 Kafka 桥接数据到 Kafka 搭建 Kafka 环境，以 MacOS X 为例: wget https : //archive.apache.org/dist/kafka/2.8.0/kafka_2.13-2.8.0.tgz tar - xzf kafka_2 . 13 - 2.8 . 0.tgz cd kafk...

Performance testing of TubeMQ vs Kafka 1 背景 2 测试场景方案 3 测试结论 4 测试环境及配置 4.1 【软件版本及部署环境】 4.2 【Broker硬件机型配置】 4.3 【Broker系统配置】 5 测试场景及结论 5.1 场景一：基础场景，单topic情况，一入两出模型，分别使用不同的消费模式、...

Performance testing of TubeMQ vs Kafka 1 背景 2 测试场景方案 3 测试结论 4 测试环境及配置 4.1 【软件版本及部署环境】 4.2 【Broker硬件机型配置】 4.3 【Broker系统配置】 5 测试场景及结论 5.1 场景一：基础场景，单topic情况，一入两出模型，分别使用不同的消费模式、...

Kafka 流处理开发简介 Kafka 流处理开发简介 在上一节，我们介绍了分布式流处理平台Kafka的运维工作，在这一节，我们将讨论Kafka的应用开发。 你可能已经注意到，这一节的标题并不是”在微服务中的集成”，而是”开发简介”。 使得，如在前文所述，Kafka的吞吐性能出色，但延迟性能一般，因此多用于离线处理的场景，典型应用有： 异源数...

Kafka消费者详解 一、消费者和消费者群组 二、分区再均衡 三、创建Kafka消费者 三、 自动提交偏移量 3.1 偏移量的重要性 3.2 自动提交偏移量 四、手动提交偏移量 4.1 同步提交 4.2 异步提交 4.3 同步加异步提交 4.4 提交特定偏移量 五、监听分区再均衡 六 、退出轮询 七、独立的消费者 附录 : Ka...

须知（Caveat emptor） 概览（Big picture） 步骤（Steps） 其他注意事项（Additional considerations） Supported Kafka versions and upgrading 支持的 Kafka 版本和升级 调试（Debugging） 例子（Example） 原文 作者 审...