消消气~
你注意到的“topichtmltrack_errorisn'talreadymarkedafterdeletion”是正常的。kafka删掉topic的过程事实上是异步的:命令行单单是递交一个删除再申请给到controller,并标志该topic为“待删除”状态。当然在kafka服务器端唯一的删除掉逻辑应该要早传送,正常情况下您不需要多等待一段时间topic自然会被完成删掉。
另一个相当于的kafka服务器被被称broker。broker收得到来自生产者的消息,为消息设置中偏移量,并并提交消息到磁盘保存到。broker为消费者提供服务,对读取数据主分区的请求做出了决定相应,前往也并提交到磁盘上的消息。
kafka的消息按照主题(topic)并且分类,就好比是数据库的表,也可以是文件系统里的文件夹。主题是可以被分为若干个分区(partition),一个分区应该是个递交日志。消息以赏分的读取分区,然后以先进先出的顺序读取。特别注意,的原因一个主题像是包涵几个分区,但根本无法在整个主题范围内可以保证消息的顺序,但可以只要消息在单个分区内的顺序。主题是逻辑上的概念,在物理上,一个主题是横跨多个服务器的。
有以下几种:
activemq:每个人一开始都建议使用activemq,但现在的确每个人都还没有使用太。已通过如此大规模吞吐量方案不验证,社区也不是很活跃。单台机器的吞吐量为10,000级,并且吞吐量低的rocketmq和kafka。这是一个数量级,呐喊之声为ms级,有较低数据丢失的可能性。
rabbitmq:单机吞吐率是万级,吞吐率比rocketmq和kafka低一个数量级,但是它适合中小企业,因为它具有友好的监视和能维护界面,社区总体活跃,全都每月都有都会查找几个版本,近年来,一些国内的互联网公司更多地建议使用了rabbitmq,但问题也很的确。rabbitmq的吞吐量虽然相对较低。这是毕竟他做的实现机制比较比较忙碌不堪,但是该语言国内会的太少。
rocketmq:单机吞吐量为100,000级。rocketmq还是奇异也可以支持高吞吐量的mq。主题是可以都没有达到数百或数千个级别,另外吞吐量将略微降到。这是rocketmq的通常优势。在同一台机器上,它也可以意见大量topic,可用性太高,源代码是java。
kafka:单机吞吐量为100,000级。这是kafka的的最优势,即高吞吐量。通常与大数据系统依靠先执行实时数据算出,日志收集等场景。当topic从数十个时变数百个时,吞吐量将大吓会下降