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

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

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

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

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

1.什么是存儲過程 很多時候，SQL語句都是針對一個或多個表的單條語句。但是也有時候有的查詢語句需要進行多次聯表查詢才能完成，此時就需要用到存儲過程了。 存儲過程（Stored Procedure ...

　　今天有點時間，我就來說兩句。最近接觸的Kafka相關的東西要多一些，其實以前也接觸過，但是在項目使用中的經驗不是很多。最近公司的項目里面使用了Kafka消息中間件，由於以前的人員編寫的客戶 ...

前言: 　　kafka是linkedin開源的消息隊列, 淘寶的metaq就是基於kafka而研發. 而消息隊列作為一個分布式組件, 在服務解耦/異步化, 扮演非常重要的角色. 本系列主要研究k ...

1.消息發送mq不丟失實現方式 上面是發送RocketMq的事務消息發送方法 下面是RocketMq的事務消息發送方法的回調函數的實現類 以上就是R ...

brokers和消費者使用zk來獲取狀態信息和追蹤消息坐標。 每一個partition是一個有序的，不可變的消息序列。 只有當partition里面的file置換到磁盤文件以后，才開放給消費者來消費。 ...