kafka 设置topic 用户名密码 如何删除weblogicjmsdelayed状态的消息？
如何删除weblogicjmsdelayed状态的消息？
消消气~
你注意到的“Topichtmltrack_errorisn'talreadymarkedafterdeletion”是正常的。Kafka删掉topic的过程事实上是异步的：命令行单单是递交一个删除再申请给到controller，并标志该topic为“待删除”状态。当然在Kafka服务器端唯一的删除掉逻辑应该要早传送，正常情况下您不需要多等待一段时间topic自然会被完成删掉。
kafka broker与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从数十个时变数百个时，吞吐量将大吓会下降
版权声明：本文内容由互联网用户自发贡献，本站不承担相关法律责任.如有侵权/违法内容,本站将立刻删除。
