Kafka 生产者守护进程 Bruce

Apache
C/C++
Linux
2014-09-10
小编辑

Bruce 是 Apache Kafka 的生产者守护进程,它简化了客户端发送消息到 Kafka ,无需关注后端的 Kafka 集群。Bruce 主要处理:

  • Routing messages to the proper brokers, and spreading the load evenly across multiple partitions for a given topic

  • Waiting for acknowledgements, and resending messages as necessary due to communication failures or Kafka-reported errors

  • Buffering messages to handle transient load spikes and Kafka-related problems

  • Tracking message discards when serious problems occur; Providing web-based discard reporting and status monitoring interfaces

  • Batching and compressing messages in a configurable manner for improved performance

Bruce runs on each individual host that communicates with Kafka, receiving messages from local clients over a UNIX domain datagram socket. Clients write messages to Bruce's socket in a simple binary format. Once a client has written a message, no further interaction with Bruce is required. From that point onward, Bruce takes full responsibility for reliable message delivery. Bruce serves as a single intake point for a Kafka cluster, receiving messages from diverse clients regardless of what programming language a client is written in. Client code is currently available in C, C++, Java, Python, and PHP. Code contributions for clients in other programming languages are much appreciated. Technical details on how to send messages to Bruce are provided here. Bruce runs on Linux, and has been tested on CentOS versions 7 and 6.5, and Ubuntu versions 14.04.1 LTS and 13.10. Bruce requires at least version 0.8 of Kafka.

加载中

评论(0)

暂无评论

暂无资讯

暂无问答

Quote

TRUST NO ONE

2015/07/19 14:32
17
0
mongoDB JAVA操作

类转换 当把一个类对象存到mongoDB后,从mongoDB取出来时使用setObjectClass()将其转换回原来的类。 public class Tweet implements DBObject { /* ... */ } Tweet myTweet = new Tweet(); ...

2011/06/30 09:27
3.1K
1
XPath编写规则学习总结

XPath编写规则学习 辅助工具:firefox安装findbugs,view Xpath firefox :Xpath验证方式:$x("xpath"); 粘贴xpath语句回车即可 定位: 1、依靠自己属性,文本定位: //td[text()='test'] //...

2016/06/26 10:21
73
0
navicat 在ubuntu  试用过期的方法

navicat 在ubuntu  试用过期的方法

2016/09/05 11:16
215
0
JavaScript引用类型Array实例分析

1、ECMAScript数组的特点 ECMAScript数组的每一项可以保存任何类型的数据。 ECMAScript数组的大小是可以动态调整的。 2、创建数组 (1)使用Array构造函数(new操作符可省略) var arr1 = n...

2018/11/10 20:30
10
0
Python 为什么要保留显式的 self ?

花下猫语:前两天,我偶然在一个知识星球(刘欣老师的“码农翻身”)里看到一篇主题,刘老师表示 Python 的类方法非要带个 self,而不像其它语言那样隐藏起来,这让人很不爽。我对此也有同感...

09/28 11:02
33
0
mongodb学习笔记3(几种查询)

今天主要学习的是条件操作符进行查询,主要是以下几个: $gt : > $lt : < $gte: >= $lte: <= $ne : !=、<> $in : in $nin: not in $all: all $not: 反匹配 下面举例把用法说一下: 查询 name...

2013/06/10 01:23
213
0
sicily 1211 商人的宣传

Description Bruce是K国的商人,他在A州成立了自己的公司,这次他的公司生产出了一批性能很好的产品,准备宣传活动开始后的第L天到达B州进行新品拍卖,期间Bruce打算将产品拿到各个州去做推销...

2013/01/17 18:28
164
0
Ubuntu无损分区调整

问题的起因是这样的,自己有一台Ubuntu的家庭服务器。硬盘是1T的。安装系统的时候呢,没有多想。直接默认安装了。也就是说整个一个1T的硬盘都mount到/了。没有自己的数据分区,重做系统的时候...

2013/05/19 18:50
8.9K
3
java 奇闻佚事

java 奇闻佚事 , 今天第一次,想着写点这东西。 C3P0 感觉是从星球大战中来的 欢迎补充。。。。哈哈。。

2015/09/11 23:59
186
0

没有更多内容

加载失败,请刷新页面

返回顶部
顶部