下載 http://www.confluent.io/download，打開后，顯示最新版本3.0.0,然后在右邊填寫信息后，點擊Download下載。 之后跳轉到下載頁面，選擇zip 或者 tar都行， 下載完成后上傳linux系統，解壓即完成安裝。 zip ...

今天我們要講的大數據公司叫作Confluent，這個公司是前LinkedIn員工出來后聯合創辦的，而創業的基礎是一款叫作Apache Kafka的開源軟件。 Confluen聯合創始人Jun Rao即將在QCon北京2018分享Apache Kafka的前世今生和未來的相關話題。 在整個 ...

上個章節我們講了kafka的環境安裝（這里），現在主要來了解下Kafka使用，基於.net實現kafka的消息隊列應用，本文用的是Confluent.Kafka，版本0.11.6 1、安裝： 在NuGet程序包中搜索“Confluent.Kafka”下載安裝即可 2、producer ...

我們把Kafka比作Linux的內核,Confluent就相當於Linux的某個發行版。Confluent提供了Kafka沒有的組件和功能，比如完善的跨數據中心數據備份以及集群監控解決方案。 Confluent還分開源版本和企業版本,企業版本中提供了對底層Kafka集群完整的可視化監控解決方案 ...

針對golang的 kafka client 有很多開源package，例如sarama, confluent等等。在使用sarama 包時，高並發中偶爾遇到crash。於是改用confluent-kafka-go，其簡單易用，並且表現穩定。 本文主要介紹 ...

概述 背景 Apache Kafka 是最大、最成功的開源項目之一，可以說是無人不知無人不曉，在前面的文章《Apache Kafka分布式流處理平台及大廠面試寶典》我們也充分認識了Kafka，Apache Kafka 是LinkedIn 開發並開源的，LinkedIn 核心理念之一數 ...

之前寫過兩篇關於重置offset的博文，后來使用過程中都有問題。 經過各種嘗試，終於找到了解決方案。 直接上代碼： 代碼中的while循環是防止有時連不上kafka服務器報錯。 很奇怪，我直接用c.commit(offsets=[tp_c])不起作用，非要我消費后它自動重置 ...

kafka 入門筆記（#1） 單機測試 下載版本，解壓 啟動服務 Kafka用到了Zookeeper ，所以首先要啟動zookeeper，先啟動一個單實例的zk服務。 啟動Kafka 服務 創建 topic 創建一個 名叫“test”的topic ，只有一個分區，一個副本 ...