首页
学习
活动
专区
工具
TVP
发布

JavaEdge

关注公众号:JavaEdge,加入全国最大的后端交流群。
专栏作者
2432
文章
2418148
阅读量
175
订阅数
图解Kafka Producer常用性能优化配置参数
涉及到消息发送是如何工作的,本节首先将罗列参数,做简单说明,然后再给出运作图,进一步阐述其工作机制。
JavaEdge
2024-01-03
1890
实时数据系统设计:Kafka、Flink和Druid
对于使用批处理工作流的数据团队来说,要满足当今的实时需求并不容易。为什么呢?因为批处理工作流,从数据传递和处理到分析,涉及很多等待。
JavaEdge
2023-12-18
2730
全网最全图解Kafka适用场景
消息系统被用于各种场景,如解耦数据生产者,缓存未处理的消息。Kafka 可作为传统的消息系统的替代者,与传统消息系统相比,kafka有更好的吞吐量、更好的可用性,这有利于处理大规模的消息。
JavaEdge
2023-11-25
1290
Kafka Tool模拟数据发送
📷 📷
JavaEdge
2023-03-31
8990
金融业务如何高性能传输数据
券商发给交易所的订单数据属于事务数据。这里的事务指的是数据库事务(Transaction)。所以交易数据的传输需满足顺序正确性要求,既要保证顺序的正确性,也要保证消息处理的一次性。
JavaEdge
2022-12-30
4420
关注专栏作者,随时接收最新技术干货
JavaEdge
华为软件开发工程师
kafka单条消息过大导致线上OOM,运维连夜跑路了!
查看日志,发现Pro程序爆异常kafka.common.MessageSizeTooLargeException。
JavaEdge
2022-12-20
3870
如何保证消息恰好被消费一次?
因为业务逻辑从同步代码中移除,所以也要有相应队列处理程序处理消息、执行业务逻辑。随着业务逻辑复杂,会引入更多外部系统和服务,就会越来越多使用MQ,与外部系统解耦合以及提升系统性能。
JavaEdge
2022-11-30
3360
Kafka是如何应用NIO实现网络通信的?
Acceptor和Processor之间缓存SocketChannel newConnections队列,保证线程安全顺序。
JavaEdge
2022-11-30
2910
【大厂消息队列】面试解析(2)-MQ选型
方便可以修改源代码,而非一味地等待软件提供商猴年马月发布的下个版本解决。在知识产权下,使用开源的才可商用。
JavaEdge
2022-11-30
5840
Kafka实战(3)-Kafka的自我定位
Kafka对消息保存时根据Topic进行归类,发送消息者成为Producer,消息接受者成为Consumer,此外kafka集群有多个kafka实例组成,每个实例(server)称为broker。
JavaEdge
2022-11-30
3670
消息队列面试解析系列(一)-消息队列(MQ)的意义
见名知义,消息队列主要就是用来发送和接收处理消息,但它的作用可不仅解决应用间通信问题。
JavaEdge
2022-11-30
1.4K0
Kafka实战(1)-为何大厂都选择Kafka作为消息队列
MQ是一组规范。 利用这组规范可以在不同系统间传递语义准确的消息,实现松耦合的异步式数据传递。
JavaEdge
2022-11-30
5930
Kafka实战(7)-究竟该如何部署Kafka集群?
生产环境需考量各种因素,结合自身业务需求而制定。看一些考虑因素(以下顺序,可是分了顺序的哦)
JavaEdge
2022-11-30
3860
Kafka实战(2)-Kafka消息队列模型核心概念
Kafka发布订阅的对象是主题(Topic),可为每个业务、每个应用甚至是每类数据都创建专属的主题。
JavaEdge
2022-11-30
3420
Kafka实战(四) -Kafka门派知多少
Kafka不是一个单纯的消息引擎系统,而是能够实现精确一次(Exactly-once)处理语义的实时流处理平台
JavaEdge
2022-11-30
3720
Flink实战(八) - Streaming Connectors 编程
Flink内置了一些基本数据源和接收器,并且始终可用。该预定义的数据源包括文件,目录和插socket,并从集合和迭代器摄取数据。该预定义的数据接收器支持写入文件和标准输入输出及socket。
JavaEdge
2022-11-30
1.9K0
Flink实战(八) - Streaming Connectors 编程
Flink内置了一些基本数据源和接收器,并且始终可用。该预定义的数据源包括文件,目录和插socket,并从集合和迭代器摄取数据。该预定义的数据接收器支持写入文件和标准输入输出及socket。
JavaEdge
2022-11-30
1.9K0
突破Java面试(18)-消息队列面试技巧总结
其实如果我是面试官的话,我如果感觉你都把刚才那些问题都答出来了,我可能会继续刨根问底,深挖,问你,直到把你给问倒
JavaEdge
2022-11-30
2580
RabbitMQ面试必备知识点及实战(二)-核心概念
开源的消息代理和队列服务器,通过普通协议在完全不同的应用间共享数据,使用Erlang语言编写,并且基于AMQP协议。
JavaEdge
2022-11-30
3140
突破Java面试(9)-如何保证消息队列的顺序性
应该得保证消息按照顺序执行的吧! 不然本来是:增加->修改->删除 你楞是换了顺序给执行成:删除->修改->增加 全错!!!
JavaEdge
2022-11-30
2880
点击加载更多
社区活动
Python精品学习库
代码在线跑,知识轻松学
【玩转EdgeOne】征文进行中
限时免费体验,发文即有奖~
博客搬家 | 分享价值百万资源包
自行/邀约他人一键搬运博客,速成社区影响力并领取好礼
技术创作特训营·精选知识专栏
往期视频·干货材料·成员作品·最新动态
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档