kafka概念　　Topic：消息根据Topic进行归类，可以理解为一个队里。　　Producer：消息生产者，就是向kafkabroker发消息的客户端。　　Consumer：消息消费者，向kafkabroker取消息的客户端。　　broker：每个kafka实例(server)，一台kafka服务器就是一个broker，一个集群

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

Kafkatopicleader均衡(about:blank%E8%83%8C%E6%99%AF"背景")背景在创建一个topic时，partition会在Br

\Kubernetes相关博客\Kubernetes官方社区\(https://kubernetes.io/)\K8smeetup\(http://www.k8smeetup.com/)\Dockone社区\(http://dockone.io/topic/Kubernetes)\才云官方技术博客

kafka参数配置详情：publicfinalBrokerHostshosts;//设置kafka从哪里获取相关的配置信息publicfinalStringtopic;//从哪个topic开始消费publicfinalStringclientId;//设置客户端标识publicintfetchSizeBytes10

KafkaMonitor为Kafka的可视化管理与监控工具，为Kafka的稳定运维提供高效、可靠、稳定的保障，这里主要简单介绍KafkaMonitor的相关功能与页面的介绍；　　KafkaMonitorv0.1主要功能有：Kafka基本信息仪表盘、broker列表、topic列表、当前消费者列表、Topic添加删除、Topic数据

“读万卷书，行万里路”。我觉得这句话用在程序员的工作中就是：在网络中找一万篇资料，在实践中做一万种尝试。<hr\\20140917：\\\\在本文中，由于作者事先不了解，设计不合理，使每个设备采用prefixCLIENT\_ID的方式作为topic，导致需要给每个设备的topic单独推送，才产生了一些问题，特别是推送的时间上的

1.rabbitmq消息监听，兼容多种模式的消息，fanout/topic等模式MQ消息配置监听：packagecom.test.ddyin.conf;importjava.util.HashMap;importjava.util.List;importjava.util.function.Pr

1，activemq分为queue和topic两种2，下面先介绍queue，使用spring集成build.gradlecompile"org.springframework:springjms:3.2.1.RELEASE"compile"org.apache.activemq:activemqcore

ActiveMQ3.Java编码实现ActiveMQ通讯3.1.队列（Queue）目的地（Destination）分为：点对点的队列（Queue）一对多的主题（Topic）3.1.1.上手代码1.pom.xml

目前Kafka并没有提供直接的工具来帮助我们获取某个topic的当前总消息数，需要我们自行写程序来实现。下列代码可以实现这一功能，特此记录一下：/获取某个topic的当前消息数Java8only@paramtopic@

Kafka的版本间差异较大，下面是0.8.1的操作方法首先cd到kafaka的bin目录下，操作kafka的工具都在这里呢。如果发现找不到，或者名字不对，说明kafka版本不对。以topic是test为例子zookeeper后的ip改成你们自己的创建topic./kafkatopics.shtopictestcreate

慢消费者：消费消息过慢的consumer/subscriber。慢消费者会对broker产生影响，尤其是nondurable的topic和queue，topic尤甚，会导致broker的内存爆满，阻塞publisher。1\.NondurableTopics受慢消费者影像最大，发送到nond

1.若没有分区，一个topic对应的消息集在分布式集群服务组中，就会分布不均匀，即可能导致某台服务器A记录当前topic的消息集很多，若此topic的消息压力很大的情况下，服务器A就可能导致压力很大，吞吐也容易导致瓶颈。有了分区后，假设一个topic可能分为10个分区，kafka内部会根据一定的算法把10分区尽可能均匀分布到不同的服务器上，比如：A服务

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

SELECT  其他字段,  SUBSTRING\_INDEX(SUBSTRING\_INDEX(a.'逗号分隔字段',',',b.help\_topic\_id1),',',1)AS'分拆后字段' FROM  \表\ASa  JOINmysql.help\_topicAS

ActiveMQ3.Java编码实现ActiveMQ通讯3.1.队列（Queue）目的地（Destination）分为：点对点的队列（Queue）一对多的主题（Topic）3.1.1.上手代码1.pom.xml

https://groups.google.com/forum/!topic/seastardev/RuKOajeqHkhttps://www.google.com/search?eigTHWtr5O4WQsAWio7wCQ&qdl\_iterate\_phdrgccexception&oqdl\_iterate\_phdrgcc

XML及属性配置1.业务处理(kiafka.worker.xml)<?xmlversion"1.0"encoding"UTF8"?<root<topics<!name:要消费的topic;<!worker:执行消费逻辑的worker,配置值为执行的类

1、抛出问题一个新的消费组订阅一个已存在的Topic主题时，消费组是从该Topic的哪条消息开始消费呢？首先翻阅DefaultMQPushConsumer的API时，setConsumeFromWhere(ConsumeFromWhereconsumeFromWhere)API映入眼帘，从字面意思来看是设置消费者从哪里开始消费，正是解