暂无搜索历史
我们往kafka集群中发送数据的时候，kafka是怎么感知到需要发送到哪一台节点中呢？其实这其中的奥秘就在kafka的Metadata中。这一篇我们就来看看ka...
Kafka是一个分布式的事件流平台，可以让你跨多台机器读、写、存储和处理事件(在文档中也称为记录或消息)。
所谓的副本机制（Replication），也可以称之为备份机制，通常是指分布式系统在多台网络互联的机器上保存有相同的数据拷贝。副本机制有什么好处呢？
消息队列中间件是分布式系统中重要的组件，主要解决应用解耦，异步消息，流量削锋等问题，实现高性能，高可用，可伸缩和最终一致性架构。目前使用较多的消息队列有Acti...
Kafka 是对分区进行读写的，对于每一个分区的消费，都有一个 offset 代表消息的写入分区时的位置，consumer 消费了数据之后，每隔一段时间，会把自...
突然出现一个任务需要对kafka处理的数据进行插队操作（内心小崩溃。。。），研究了一下，还是可以使用拦截器进行实现这样的效果的。
kafka依赖于ZooKeeper，如果以单机模式调试kafka，需要确保本机已经安装了ZooKeeper，并处于启动状态。
如上图所示是模拟客户的业务网页构建的一个并发访问模型。用户在页面点击从而产生一个HTTP请求，这个请求发送到业务生产进程，就会启动一个投递线程（Deliver ...
KafkaProducer 是线程安全的，可以在多个线程中共享单个 KafkaProducer 实例，也可以将 KafkaProducer 实例进行池化来供其他...
网上有很多消息队列的中间件，如redis,kafka,rabbitmq,这些都很强大 但用起来，每个的用法都不一样，有没有一种办法，我只需要实现一种方法，就能...
Kafka 是一个高性能的消息队列，在众多消息队列产品中，Kafka 的性能绝对是处于第一梯队的。我曾经在一台配置比较好的服务器上，对 Kafka 做过极限的性...
TimingWheel是kafka时间轮的实现，内部包含了⼀个TimerTaskList数组，每个数组包含了⼀些链表组成的TimerTaskEntry事件，每个...
kafka没有重试机制不⽀持消息重试，也没有死信队列，因此使⽤kafka做消息队列时，需要⾃⼰实现消息重试的 功能。 实现 创建新的kafka主题作为重试...
kafka是一种高吞吐量的分布式发布订阅消息系统。生产者发送消息到队列中，消费者消费其中的消息。
1）修改application.properties文件中Mysql数据库的相关配置
一、消息队列概述 消息队列中间件是分布式系统中重要的组件，主要解决应用解耦，异步消息，流量削锋等问题，实现高性能，高可用，可伸缩和最终一致性架构。目前使用较多...
消息队列中间件是分布式系统中重要的组件，主要解决应用耦合、异步消息、流量削锋等问题，具有高扩展性、可恢复性、送达保证、顺序保证等特点，可以实现高性能、高可用、可...
进入Kafka Eagle目录，进入conf目录修改system-config.properties配置文件内容如下
暂未填写个人简介
暂未填写个人网址
