在kafka/config/目錄下面有3個配置文件： (1).producer.properties:生產端的配置文件 (2).consumer.properties:消費端的配置文件 ...

1.啟動Kafka，其中">>/dev/null"表示將日志信息輸出到"黑洞"，其中"2>&1"表示將錯誤信息和前面的日志信息一樣，也輸出到"黑洞"，末尾的"&"表示 ...

案例分析 處理kafka consumer的程序的時候，發現如下錯誤： 如上log可以看出，問題就是有一個較大的消息數據在codeTopic的partition 3上，然后consumer未能消費，提示我可以減小broker允許進入的消息數據的大小，或者增大consumer程序消費數據 ...

場景: 在一個線程內,使用相同的brokers和group id等配置,根據傳入的topic數量N,分別定義N個consumer,按定義順序先后調用consumers消費 現象: 程序啟動后,kafka消費線程正常初始化,調用poll嘗試消費,一直沒有返回消息. 程序啟動10分鍾左右后,開始正常 ...

使用spring+springMVC+mybatis+kafka做了兩個web項目，一個是生產者，一個是消費者。 通過JMeter測試工具模擬100個用戶並發訪問生產者項目，發送json數據給生產者 ...

錯誤日志： 2019-10-11 17:50:48.744 WARN []-[o.a.k.clients.consumer.ConsumerConfig :173] The configuration num.replica.fetchers = 1 was supplied but isn't ...

一、引言 　　研究Kafka有一段時間了，略有心得，基於此自己就寫了一個Kafka的消費者的類和Kafka消息生產者的類，進行了單元測試和生產環境的測試，還是挺可靠的。 二、源碼 　　話不多說， ...

kafka客戶端中使用了很多的回調方式處理請求。基本思路是將回調函數暫存到ClientRequest中，而ClientRequest會暫存到inFlightRequests中，當返回respon ...

　　本文接着上一篇寫的《Java微服務（一）：dubbo-admin控制台的使用》，上篇文章介紹了docker，zookeeper環境的安裝，並參考dubbo官網演示了dubbo-admin控制台的使 ...

前言: 　　之前也寫過dubbo的filter的文章, 后來和同事也有過交流, 才發生自己對dubbo的filter的機制, 還是存在一些誤解, 尤其是自定義filter的定位, 不是那么清晰. ...