Kafka

CTO 觀點：如何為企業選擇合適的訊息系統？

在這種情況下，因為我們不需要 Kafka API 的獨有特性，所以我們沒有使用支援 Kafka 協議（KOP）的 Pulsar Broker，而是選擇 Pulsar API，因為 Pulsar API 支援所有我們需要 Kafka API ...

副本資料同步策略我們知道kafka的partition是主從結構的，因此當一個topic對應多個partiton時，為了保證leader掛掉之後，能在follower中選舉出新的leader且不丟失資料，就需要確保follower與lead...

（二）方案架構及優勢根據以上實時指標統計場景，設計瞭如下架構圖：涉及產品列表：本地資料中心（IDC）的自建Kafka叢集私有網路VPC專線接入/雲聯網/VPN連線/對等連線流計算Oceanus （Flink）雲資料庫Redis二、前置準備購...

本篇文章主要是druid 在kafka 載入資料的配置...

我們可以重新建立源聯結器，並實現相同表的再次流化處理，然而，我們的聚合會根據 CDC 資料和從 Kafka 檢索的當前實體狀態之間的差異來生成事件...

標準做法也是透過kafka-reassign-partitions指令碼完成，不過使用者可直接往Zookeeper中寫資料來實現，比如直接把新增分割槽的副本集合寫入到/brokers/topics/下，然後controller會為你自動地選...

⑨KIP-733：更改 Kafka Streams 預設複製因子配置有了主要版本的機會，Streams 配置屬性的預設值replication...

KIP-733：更改 Kafka Streams 預設複製因子配置有了主要版本的機會，Streams 配置屬性的預設值replication...

我們將使用本部落格的其餘部分來說明此版本中的三個功能如何改進平臺 - Impala 行過濾、Atlas / Kafka 整合和 Ranger 審計過濾器和策略...

什麼是Kafka消費者...

騰訊雲中間件 - 微服務產品中心技術總監韓欣對 InfoQ 說，“在以前的版本中，ZooKeeper 可以說是 Kafka 叢集的靈魂...