Apache的Kafka是一个分布式流平台。这到底意味着什么？它可以让你发布和订阅记录流。在这方面，它类似于一个消息队列或企业消息系统。它可以让你持久化收到的记录流，从而具有容错能力。进行相应的处理。Kafka集群分类存储的记录流被称为主题。保证了消息不变

/data/kafka_2.11-1.1.0/bin/kafka-console-consumer.sh --bootstrap-server X.X.X.X:9092 --topic test --new-consumer --partition 1 -

package com;private static String topic = "test-xing";package com;private static String topic;super();this.topic = top

准备3台虚拟机, 系统是RHEL64服务版.1) 每台机器配置如下:$ cat /etc/hosts # zookeeper hostnames: 192.168.8.182 zk1 192.168.8.183 zk2 192.168.8.184 z

kafka Failed to send messages after 3 tries.起初以为是网络问题，经确认网络没有问题。这是生产者的代码 在向服务器发起连接后，在kafka的服务器配置kafka server.properties文件配置zooke

Faust是一个流处理库，将kafka流中的思想移植到Python中。它被用于Robinhood去构建高性能的分布式系统和实时数据通道，每天处理数十亿的数据。它不需要使用一个DSL，仅需要用到Python！这意味着你在做流处理的时候可以使用所有你喜欢的Py

前言kafka现在在很多地方都会有应用到，那kafka是什么呢？简介Apache Kafka是一个开源消息系统项目，该项目的目标是为处理实时数据提供一个统一、高通量、低等待的平台。0x00 历史Apache Kafka最初由LinkedIn开发，并在201

Kafka Controller 是 Kafka 的核心组件，在前面的文章中，已经详细讲述过 Controller 部分的内容。在过去的几年根据大家在生产环境中应用的反馈，Controller 也积累了一些比较大的问题，而针对这些问题的修复，代码的改动量都

4.在虚拟机中输入yum -y install lrzsz ,下载一个rz包，然后在操作时直接输入rz就能直接把文件导入到虚拟机中，我安装的是简化版的linux，里面没有unzip ,所以需要yum -y install unzip 下载unzip用来解压

前言最近在利用Spark streaming和Kafka构建一个实时的数据分析系统，对图书阅读数据进行分析，做实时推荐。Spark Streaming 模块是对于 Spark Core 的一个扩展，目的是为了以高吞吐量，并且容错的方式处理持续性的数据流。目

public class ConsumerDemo {//要读取的数据主题private static final String topic = "kfc";//消费者的数量private static fi