一个人知道的Topic是单点推送，大家都知道Topic是广播。 kafka消息消费机制： 1.广播消费：通过定义topic前缀来标识属于广播的消息（例如：topicname：gonggao1535680698557,gonggao1535680722624 ...

Kafka的安装与启动 kafka中涉及的名词 消息记录：由一个key，一个value和一个时间戳构成，消息最终存储在主题下的分区中，记录在生产中称为生产者记录，在消费者中称为消费记录。Kafka集群保持了所有发布的消息，直到它们过期，无论消息是否被消费了，在一个可配置的时间段 ...

前言 本篇文章主要介绍的是springboot整合kafka。 安装kafka 1.使用docker安装kafka，移步 https://www.cnblogs.com/lixianguo/p/13254950.html 创建工程 1.创建一个名为springboot-kafka的pom ...

Kafka一般适用日志传输，而RocketMQ适用非日志的可靠性传输（日志传输也可以）。接下来我们将讨论它俩区别，你们就知道哪种情况用RocketMQ。其实，RocketMQ是阿里开发的，大家都知道，阿里的淘宝非常强，所以这个是对网上商城非常方便。 数据可靠性 RocketMQ支持异步 ...

作者 | 元毅 阿里云智能事业群高级开发工程师 导读：当前在 Knative 中已经提供了对 Kafka 事件源的支持，那么如何基于 Kafka 实现消息推送呢？本文作者将以阿里云 Kafka 产品为例，给大家解锁这一新的姿势。 背景 消息队列 for Apache Kafka ...

聊聊最近，2020年，在2019年的年尾时，大家可谓对这年充满新希望，特别是有20200202这一天。可是澳洲长达几个月的大火，新型冠状病毒nCoV的发现，科比的去世等等事情，让大家感到相当的无奈，生 ...

springboot集成kafka是比较简单的是事情，但是kafka发送消息的失败回调在日常工作中，如果不容忍消息丢失的话，发送失败需要再次发送或者放到数据库中用任务重推。以下是演示用的发送类代码 在kafka运行过程中kill进程达到异常发送的条件。 ...

在kafka的config文件夹中的server.config： 在#listeners=PLAINTEXT://:9092下加一行 listeners=PLAINTEXT://localhost:9092 参考：https://www.jianshu.com/p/b6a5045434c4 ...