使用Netty采集Kafka的数据 使用Java Netty构建一个HTTP服务器，该服务器接受一个JSON对象并将其保存到Kafka队列中。 为此，请在开发机器上设置netty / kafka。 需要Java和Maven的有效安装。 基于： : Apache Kafka初始化 步骤1：下载程式码 wget http://ftp.halifax.rwth-aachen.de/apache/kafka/2.3.0/kafka_2.12-2.3.0.tgz tar -xzf kafka_2.12-2.3.0.tgz cd kafka_2.11-1.0.1 步骤2：启动ZooKeeper服务器 bin/zookeeper-server-start.sh config/zookeeper.properties 步骤3：启动Kafka服务器： bin/kafka-server-st

多易Flink Flume hive kafka课程知识图谱与配套资料

查看kafka上面数据的可视化工具, kafkatool-1.0.exe, 可以查看kafka 0.11一下版本：0.8, 0.9, 0.10

KafkaOffsetMonitor是kafka监控工具，用来监控Kafka的消费组以及它们所在的分区中的Offset，每个Topic的所有分区的消费情况都可以一目了然，下载jar文件上传到linux服务器上，修改start.sh中的zookeeper、kafka地址，然后执行sh start.sh

将该jar包上传至flume/lib目录下，并将spark-streaming-flume其他版本jar包删除即可使用，该jar包适用于spark2.1.3版本使用

微博热搜情绪分析.docx

kafka扩容方案-kafka-manager重新分配topic

Kafka是一种高吞吐量的分布式发布订阅消息系统，有如下特性： 高吞吐量，即使是非常普通的硬件Kafka也可以支持每秒数百万的消息。

kafka和zookeeper

Kafka技术实战学习的优选课程，课程内容全程实战，没有拖泥带水，但不包含基础知识的教学，需要同学们先具备一定的Kafka技术基础再进行学习。课程内容包括了Kafka java Consumer实战，Kafka集成框架等。