一、kafka 簡介 kafka是一種高吞吐量的分布式發布訂閱消息系統，它可以處理消費者規模的網站中的所有動作流數據。這種動作（網頁瀏覽，搜索和其他用戶的行動）是在現代網絡上的許多社會 ...

　　今天要介紹的是消息中間件KafKa，應該說是一個很牛的中間件吧，背靠Apache 與很多有名的中間件搭配起來用效果更好哦 ，為什么不用RabbitMQ，因為公司需要它。 　　網上已經有很多怎么 ...

步驟如下：a、假如topic1,具有如下partitions: P0,P1,P2,P3。b、加入group中,有如下consumer: C1,C2。c、首先根據partition索引號 ...

1、Kafka的消費者提交方式 　　1）、自動提交，這種方式讓消費者來管理位移，應用本身不需要顯式操作。當我們將enable.auto.commit設置為true，那么消費者會在poll方法調用后每 ...

1、kafka官網：http://kafka.apache.org/downloads jdk：https://www.oracle.com/technetwork/java/javase/down ...

其實很早就是用kafka了，但是一直都用的非常簡單，最近寫一個小功能的時候又要用到kafka，於是就花點時間好好看了一下網上關於kafka的一些文檔和博客，發現了一個很不錯的博客，做個記錄和分享。 原 ...

1、啟動kafka的時候，報錯如下所示： 2、原因分析，主要是自己是hadoop用戶操作，期間無意登陸到root權限，啟動了kafka,且啟動成功了，創建了如下所示的目錄，而且權限是r ...

目錄 1、背景引入：很多同學看不懂Kafka參數 2、一段Kafka生產端的示例代碼 3、內存緩沖的大小 4、多少數據打包為一個Batch合適？ 5、要是一個Batch遲遲無法湊滿咋辦？ ...

1、搭建部署好zookeeper集群和kafka集群，這里省略。 2、生產者和消費者代碼如下所示： 消費者代碼如下所示： 遇到的坑，一開始報的錯誤莫名其 ...

1、之前搭建的kafka，過了好久，去啟動kafka，發現報如下下面的錯誤，有錯誤就要解決了。 然后參考：https://blog.csdn.net/hello_world_qwp/article/ ...