kafka启动(使用kafka内置的Zookeeper和KRaft启动kafka)
kafka启动(使用kafka内置的Zookeeper和KRaft启动kafka)
Kafka中的偏移量消费问题_earliest和latest区别
1没有偏移量提交,针对的消费者的groupid对应的偏移量2请求的的偏移量在broker上不存在时,会怎么消费kafka。
Kafka 的基本概念
理解 Kafka 的基本概念,包括 Consumer,Broker,Producer,Partition,Topic
Kafka 详细解释
Kafka 作为分布式流处理平台,凭借其高吞吐量、水平扩展性和可靠的持久化存储,成为了现代数据流处理系统的中坚力量。Kafka 的广泛应用场景从日志收集、实时数据管道到事件驱动系统,展示了它在大数据和流处理中的核心作用。然而,使用 Kafka 时也需要面对诸如顺序性、数据重复和可靠性等挑战,合理的设
centos7安装Kafka单节点环境部署二-安装与配置kafka
centos7安装Kafka单节点环境部署二-安装与配置kafka
【RabbitMQ 项目】服务端:服务器模块
服务端:服务器模块
【RabbitMQ 项目】客户端:信道模块
客户端:信道模块
【头歌】ZooKeeper之分布式环境搭建 答案
ZooKeeper之分布式环境搭建 答案第1关 ZooKeeper之仲裁模式第2关:伪分布式体验及分布式安装配置
Kafka之RecordAccumulator
这篇文章将主要介绍 Kafka 生产者中的 RecordAccumulator。RecordAccumlator 负责对生产者将要发送的消息进行分组缓存,其内部对每个 topic 维持了一个 TopicInfo 来存储缓存的消息,TopicInfo 内部对该 topic 的每个 partition
排查 Kafka 生产者服务问题的实战经验总结(dubbo的Serializable 问题)
java领域优质创作者🌐。
【RabbitMQ应用篇】常见应用问题
介绍了RabbitMQ等消息队列中间件的相关应用问题:比如如何保证消息幂等性、如何保证消息顺序性、如何解决消息积压问题
Hadoop的HA模式搭建
准备三台虚拟机1.修改虚拟机的IP地址和hostname2.配置集群中的ip映射(/etc/hosts)3.关闭虚拟机的防火墙4.集群间实现免密登录每台虚拟机都执行类似操作。
RabbitMQ创建交换机和队列——配置类 & 注解
direct模式由于要绑定多个KEY,每一个Key都要编写一个binding,会非常麻烦,基于配置类适用与简单的情况,所以我们就可以基于注解来声明交换机、队列和绑定关系。:通配符订阅,与Direct类似,只不过RoutingKey可以使用通配符(# (一个或多个单词)和 * (一个单词))。步骤一:
Hadoop本地运行模式环境搭建
学校Hadoop实验课,课前已经配置好了,最后需要提交实验报告,只能重新配置一遍。
spark任务优化参数整理
Hadoop_MRSpark_Corespark.executor.memory 默认值1gspark.executor.cores 默认值1核spark.executor.instances 默认值2个spark.yarn.am.memory 默认值512ms
无人机开发------------集群去中心化分布式通信实现
这是一个困扰了我很久的问题-------关于如何实现无人机集群的去中心化分布式通信。对于现在大多数通信,比较多的就是星型通信拓扑与树状通信拓扑,这两种方式并不是说不好,只是有一个很大的缺点就是,当中心节点或者父节点挂掉时,会影响该其余所有子节点挂掉!很严重的影响集群的动态组网的鲁棒性。直到我深入了解
关于RabbitMQ重复消费的解决方案
综上所述,避免RabbitMQ中的消息重复消费需要综合考虑多种策略和技术手段。在实际应用中,可以根据具体的业务需求和系统环境选择适合的方案。RabbitMQ在多种情况下可能会出现消息的重复消费。
保姆级教程教你如何安装Hadoop,实现Hadoop单机(非分布式)配置
前往阿里镜像站选择下载下载时间较久,请耐心等待。
基于Docker搭建Graylog分布式日志采集系统
Graylog是一个开源的日志管理工具,主要功能包括日志收集、解析、存储、搜索和可视化。它可以从各种数据源(如应用程序、系统和网络设备)收集日志,通过内置的解析器将日志格式化并存储在数据库中。用户可以使用其强大的搜索功能快速查找特定日志,设置告警规则以监控关键事件,且支持创建自定义仪表板和图表以可视
【RabbitMQ】快速上手
RabbitMQ 介绍上手操作