一.前言 　　任何消息队列都是万变不离其宗都是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)：保证 ...