消息队列之Kafka详解1\.什么是Kafka(about:blank1_Kafka_4)2\.Kafka架构(about:blank2_Kafka_15)(about:blank_37)3\.基本概念(about:blank3__40)4\.分区存储(about:blank4

一、配置server.properties 设置delete.topic.enabletrue如果没有设置delete.topic.enabletrue，则调用kafka的delete命令无法真正将topic删除，而是显示（

Kafka集群安装　　环境：　　　　Linux7.X　　　　kafka\_2.x　　　在linux操作系统中，kafka安装在/u04/app目录中　　1.下载　　　　 wgethttps://mirrors.cnnic.cn/apache/kafka/2.1.1/kafka\_2.112.1.1.

前提条件搭建Kafka集群进行数据迁移前，您需要保证自己的Kafka集群环境正常。本文使用阿里云EMR服务自动化搭建Kafka集群，详细过程请参见：Kafka快速入门。本文使用的EMRKafka版本信息如下：EMR版本:EMR3.12.1集群类型:Kafka软件信息:Ganglia3.7.2ZooKeeper

一Kafka概述1.1Kafka是什么在流式计算中，Kafka一般用来缓存数据，Storm通过消费Kafka的数据进行计算。1）ApacheKafka是一个开源消息系统，由Scala写成。是由Apache软件基金会开发的一个开源消息系统项目。2）Kafka最初是由LinkedIn开发

Kafka源码系列之Broker的IO服务及业务处理一，kafka角色Kafka源码系列主要是以kafka0.8.2.2源码为例。以看spark等源码的经验总结除了一个重要的看源码的思路：先了解部件角色和功能角色，然后逐个功能请求序列画图分析，最后再汇总。那么，下面再啰嗦一下，kafka的角色。kafka在生产中的使用，如下

Kafka命令行工具1.查看Kafka现有的Topic1bin/kafkatopics.shzookeeperlocalhost:2181list2.查看Topic详情1bin/kafkatopics.shzo

一、事前准备   1.kafka官网：http://kafka.apache.org/downloads.   2.选择使用版本下载.   3.kafka集群环境准备:（linux）    192.168.145.129 主机名：kafka01    192.168.145

Kafka应用开发1.了解Kafka应用开发适用场景2.熟悉Kafka应用开发流程3.熟悉并使用Kafka常用API4.进行Kafka应用开发Kafka的定义Kafka是一个高吞吐、分布式、基于发布订阅的消息系统Kafka有如下几个特点：1.高吞吐量2.消息持久化到磁

kafka测试数据生成：packagecom.dx.kafka;importjava.util.Properties;importjava.util.Random;importorg.apache.kafka.clients.producer.Producer;