下载 http://www.confluent.io/download，打开后，显示最新版本3.0.0,然后在右边填写信息后，点击Download下载。 之后跳转到下载页面，选择zip 或者 tar都行， 下载完成后上传linux系统，解压即完成安装。 zip ...

今天我们要讲的大数据公司叫作Confluent，这个公司是前LinkedIn员工出来后联合创办的，而创业的基础是一款叫作Apache Kafka的开源软件。 Confluen联合创始人Jun Rao即将在QCon北京2018分享Apache Kafka的前世今生和未来的相关话题。 在整个 ...

上个章节我们讲了kafka的环境安装（这里），现在主要来了解下Kafka使用，基于.net实现kafka的消息队列应用，本文用的是Confluent.Kafka，版本0.11.6 1、安装： 在NuGet程序包中搜索“Confluent.Kafka”下载安装即可 2、producer ...

我们把Kafka比作Linux的内核,Confluent就相当于Linux的某个发行版。Confluent提供了Kafka没有的组件和功能，比如完善的跨数据中心数据备份以及集群监控解决方案。 Confluent还分开源版本和企业版本,企业版本中提供了对底层Kafka集群完整的可视化监控解决方案 ...

针对golang的 kafka client 有很多开源package，例如sarama, confluent等等。在使用sarama 包时，高并发中偶尔遇到crash。于是改用confluent-kafka-go，其简单易用，并且表现稳定。 本文主要介绍 ...

概述 背景 Apache Kafka 是最大、最成功的开源项目之一，可以说是无人不知无人不晓，在前面的文章《Apache Kafka分布式流处理平台及大厂面试宝典》我们也充分认识了Kafka，Apache Kafka 是LinkedIn 开发并开源的，LinkedIn 核心理念之一数 ...

之前写过两篇关于重置offset的博文，后来使用过程中都有问题。 经过各种尝试，终于找到了解决方案。 直接上代码： 代码中的while循环是防止有时连不上kafka服务器报错。 很奇怪，我直接用c.commit(offsets=[tp_c])不起作用，非要我消费后它自动重置 ...

kafka 入门笔记（#1） 单机测试 下载版本，解压 启动服务 Kafka用到了Zookeeper ，所以首先要启动zookeeper，先启动一个单实例的zk服务。 启动Kafka 服务 创建 topic 创建一个 名叫“test”的topic ，只有一个分区，一个副本 ...