接着上一篇博客，本篇主要介绍Kafka的生产与消费的过程。Producers往Brokers里面的指定Topic中写消息，Consumers从Brokers里面拉去指定Topic的消息。

Apache Kafka是基于发布/订阅的容错消息系统，由Scala和Java编写，是一个分布式消息队列，具有高性能、持久化、多副本备份、横向扩展能力。

导语：当我们的公司在不断发展时，业务也是遍布全国或者已经国际化了，公司内部的各种系统也是越来越多，还要对接其它公司的系统，来实现公司业务的正常运转。这时我们通常希望各个系统是独立的，在升级版本时不会影响其它系统；或...

导语：我们来搭建一套java开发环境，用java实现一个生产者客户端和消费者客户端。

接口请求域名：ckafka.api.qcloud.com 本接口（ListInstance）用于在用户账户下获取消息队列 CKafka 实例列表。

导语：上一章节我们了解了怎么手动拼接请求URL和用API2.0签名自动生成请求URL，来调用CKafka的接口，这一章将进入开发阶段，用java实现拼接请求URL，进行API调用。...

导语：前面一章讲了Filebeat对接Ckafka，通常的场景是各种beats将数据存到CKafka，然后Logstash将从Ckafka中消息消息进行过滤，再经过Ckafka存入到Elasticsearch 。

导语：当你的业务系统既要对实时数据进行处理也要对离线数据进行分析时，这时候可以来了解一下Flume。

接口请求域名：ckafka.api.qcloud.com 本接口（CreateTopic）用于在消息队列 CKafka 实例下创建主题。

腾讯云消息队列 CKafka，分布式、高吞吐量、高可扩展性的消息服务，100%兼容开源 Apache Kafka 0.9 0.10