kafka – 第 3 页 – 智云一二三科技

java编程——Kafka，Mq和Redis作为消息队列使用时的差异有哪些

Kafkakafka是个日志处理缓冲组件，在大数据信息处理中使用。队列相比较简化了队列结构和功能，以流形式处理存储消息。

java 2023年5月18日点赞(2) 评论关闭阅读(92)

源码工程根目录下包含了若干文件夹和文件，如下图所示：Kafka工程目录文件夹和文件kafka是基于Gradle构建的多模块工程，在build.gradle文件中定义了整个工程和各个模块的相关配置。

java 2023年5月16日点赞(4) 评论关闭阅读(106)

背景我们都知道kafka是把消息存储在磁盘上的，那随着消息数量的不断增大，所占用的空间也是不断的增加的，那减少消息的占用空间就是一个优化的方向。kafka也考虑到了这一点，所以就有了消息压缩机制。

java 2023年5月16日点赞(2) 评论关闭阅读(96)

本教程展示了如何在 Spring Boot 应用程序中发布和订阅 Kafka 消息，以及如何在浏览器中实时显示消息。

java 2023年5月9日点赞(0) 评论关闭阅读(169)

kafka客户端api分为5大类，常用的是前3类AdminClient API：管理topic、broker之类的信息Producer API：发布消息到一个或多个topicConsumer API：订阅1个或多个topic，处理接收到的消息Stream API：流处理，将输入流

java 2023年5月7日点赞(1) 评论关闭阅读(147)

假如你想要有一个Queue的效果，也就是希望不停的往Queue里写数据，然后多个消费者消费，每条消息就只能给一个消费者。

java 2023年5月6日点赞(2) 评论关闭阅读(146)

此接口包含4个方法：ProducerRecordonSend：Producer在将消息序列化和分配分区之前会调用拦截器的这个方法来对消息进行相应的操作。

java 2023年4月28日点赞(1) 评论关闭阅读(131)

冷知识:JDK Timer 和 DelayQueue 底层都是个优先队列，即采用了 minHeap 的数据结构，最快需要执行的任务排在队列第一个，不一样的是 Timer 中有个线程去拉取任务执行，DelayQueue 其实就是个容器，需要配合其他线程工作。

java 2023年4月28日点赞(2) 评论关闭阅读(140)

有童鞋说,使用kafka,rabbitmq就可以了,但是呢,凡是总有特殊情况啊,比如,部署的时候,由于生产环境的原因,让尽可能少的,使用中间件,但是redis,做为实现缓冲,实现认证等必须可以让安装的.

java 2023年4月18日点赞(0) 评论关闭阅读(88)

上次的 Kafka 重启失败事件，对为什么重启失败的原因似乎并没有解释清楚，那么我就在这里按照我对 Kafka 的认识，从源码和日志文件结构去尝试寻找原因。从源码中定位到问题的根源首先把导致 Kafka 进程退出的异常栈贴出来：注：以下源码基于 kafka 0.11.0.

java 2023年4月17日点赞(0) 评论关闭阅读(95)