通过借助jmeter插件实现模拟kafka生产者，直接向指定的topic中添加消息信息，使用方式如下： 1、将下载的插件复制到jmeter的插件存放目录(jmeter安装目录/lib/ext) 2、启动jmeter，在【取样器】中选择【java请求】并添加。 3、进入新添加的【java请求】取样器，类名称选择"co.signal.kafkameter.KafkaProducerSampler" 4、填写关键参数(示例中未给出的参数根据实际需要填写)，然后执行脚本

1 解压kafka-manager-1.3.3.16.zip到任意路径下 2 修改kafka-manager-1.3.3.16\conf\application.conf文件的kafka-manager.zkhosts="localhost:2181"，改为实际的zookeeper地址 3 进入bin路径运行kafka-manager.bat(window下)或kafka-manager(linux下) 4 浏览器输入http://localhost:9000进行访问

kafka_2.11-2.2.0 kafka流信息处理平台，最新下载资源，亲测有效

避免流式传输 前言：使用scala和java混编完成，其中也涉及到python脚本来自动生成日志，linux crontab调度工具来定时执行脚本生成实时日志。生成的数据主要是模拟某学习网站学习视频课程的访问量（其中*以“ / class”开头的表示实战课程，然后通过流水线Flume + Kafka + SparkStreaming进行实时日志的收集，HBase来存储数据）* 注意事项（使用的软件工具及环境配置） hadoop-2.6.0-cdh5.7.0 hbase-1.2.0-cdh5.7.0 zookeeper-3.4.5-cdh5.7.0 spark-2.2.0-bin-2.6

kafka_2.12-2.0.0，自己配置的卡夫卡、还有zookeeper包

Kafka Streams是Kafka提供的一个用于构建流式处理程序的Java库，它与Storm、Spark等流式处理框架不同，是一个仅依赖于Kafka的Java库，而不是一个流式处理框架。除Kafka之外，Kafka Streams不需要额外的流式处理集群，提供了轻量级、易用的流式处理API。

架构注册表 Confluent Schema Registry为您的元数据提供了一个服务层。 它提供了一个RESTful接口，用于存储和检索Avro:registered:，JSON模式和Protobuf模式。 它根据指定的主题名称策略存储所有架构的版本历史记录，提供多种兼容性设置，并允许根据配置的兼容性设置以及对这些架构类型的扩展支持来演进架构。 它提供了插入到ApacheKafka:registered:客户端的序列化程序，这些客户端处理模式存储和以任何受支持的格式发送的Kafka消息的检索。 本自述文件包括以下部分： 文献资料 这是Confluent文档中指向Schema Registry页面的一些链接。 快速入门API使用示例

Kafka是一个开源流处理平台，由Scala和Java编写。Kafka是一种高吞吐量的分布式发布订阅消息系统，它可以处理消费者规模的网站中的所有动作流数据。在本课程中，你将学习到，Kafka架构原理、安装配置使用、详细的Kafka写入数据和处理数据以及写出数据的流程、新旧版本对比及运用、分区副本机制的详解、内部存储策略、高阶API直接消费数据、等等

kafka源码贡献者所作，经典实战书籍，看完大呼过瘾，在此与大家共享

centos6整合包-Nginx-Zendao-tomcat-kafka-redis-ES-php-Zookeeper... 都配置安装好了 亲测可用 反馈和自定义联系博主