一.前言 　　任何消息隊列都是萬變不離其宗都是3部分，消息生產者（Producer）、消息消費者（Consumer）和服務載體（在Kafka中用Broker指代）。那么本篇主要講解Producer端，會有適當的圖解幫助理解底層原理。 　 一.開發應用 　　首先介紹一下開發應用，如何構建一個 ...

1 背景 最近由於項目需要，需要使用kafka的producer。但是對於c++，kafka官方並沒有很好的支持。 在kafka官網上可以找到0.8.x的客戶端。可以使用的客戶端有C版本客戶端，此客戶端雖然目前看來還較為活躍，但是代碼問題還是較多的，而且對於c++的支持並不是很好 ...

簡介 kafka網站上提供了C語言的客戶端librdkafka，地址在這。 librdkafka是使用C語言根據apache kafka 協議實現的客戶端。另外這個客戶端還有簡單的c++接口。客戶端作者對這個客戶端比較上心，經常會修改bug並提交新功能。 librdkafka的基本原理和我 ...

一、Kafka設計原理參考： http://blog.csdn.net/suifeng3051/article/details/48053965?locationNum=2 http://www.cnblogs.com/metoy/p/4452124.html 二、常見問題 ...

　　在上一篇kafka入門的基礎之上，本篇主要介紹Kafka的生產者和消費者。 Kafka 生產者　　 　　kafka Producer發布消息記錄到Kakfa集群。生產者是線程安全的，可以在多個線程之間共享生產者實例。一個簡單的例子，使用producer發送一個有序的key/value(鍵值 ...

alpakka項目是一個基於akka-streams流處理編程工具的scala/java開源項目，通過提供connector連接各種數據源並在akka-streams里進行數據處理。alpakka-kafka就是alpakka項目里的kafka-connector。對於我們來說：可以用 ...

參考， https://cwiki.apache.org/confluence/display/KAFKA/0.8.0+Producer+Example http://kafka.apache.org/08/configuration.html , 0.8版本，關於producer ...

　　眾所周知，Kafka 0.11.0.0版本正式支持精確一次處理語義(exactly once semantics，下稱EOS)。Kafka的EOS主要體現在3個方面： 冪等producer：保證發送單個分區的消息只會發送一次，不會出現重復消息 事務(transaction)：保證 ...