前言 需要对Kafka有一定的了解 先抛出几个问题: spring boot kafka使用 如何配置多线程消费？...[作者空间]
前言 之前写过一篇《从源码分析如何优雅的使用 Kafka 生产者》 ，有生产者自然也就有消费者。 建议对 Kakf...[作者空间]
kafka提供了两套consumer API：高级Consumer API和低级Consumer API 1、高级...[作者空间]
KafkaConsumer(消费者)每次调用 poll()方法，它总是返回由生产者写入 Kafka但还没有被消费者...[作者空间]
kafka增加了账号认证后标志着它向企业级发展迈出了关键的一步，在这个功能后kafka也终于有了大版本，到现在已经...[作者空间]
一、为什么需要消息系统 1.解耦：允许你独立的扩展或修改两边的处理过程，只要确保它们遵守同样的接口约束。 2.冗余...[作者空间]
由于项目原因，最近经常碰到Kafka消息队列某topic在集群宕机重启后无法消费的情况。碰到这种情况，有三步去判断...[作者空间]
springboot对kafka的client很好的实现了集成，使用非常方便，本文也实现了一个在springboo...[作者空间]
一、基本概念 介绍 Kafka是一个分布式的、可分区的、可复制的消息系统。它提供了普通消息系统的功能，但具有自己独...[作者空间]
生产环境重复消费消息的问题 问题 生产环境由用户反映同一张发票收到几十条短信和相关邮件 分析用户收到短信和邮件是发...[作者空间]
背景： 最近在用kafka做消息中间件，producer从hive中读取消息发送到kafka，后端storm...[作者空间]
简介 由于项目中需要使用kafka作为消息队列，并且项目是基于spring-boot来进行构建的，所以项目采用了s...[作者空间]
Kafka实际使用过程中遇到的一些问题及解决方法： 1.关于Kafka的分区： 开始使用Kafka的时候，没有分区...[作者空间]
