消息队列RocketMQ、Kafka小计
Broker部署相对复杂，Broker分为Master与Slave，一个Master可以对应多个Slave，但是一个Slave只能对应一个Master，Master与Slave的对应关系通过指定相同的BrokerName，不同的BrokerId来定义，BrokerId为0表示Master，非0表示S
flink cep数据源keyby union后 keybe失效
flink cep数据源keyby后，再union数据源， keyby失效
Kafka 架构和原理机制 (图文全面详解)
图文详解 Kafka ，一文了解掌握 Kafka 的架构、原理、特性、应用场景、以及 Zookeeper 在 Kafka 中的作用。
Kafka重要生产参数配置建议
使用，可以保证消息的顺序性，假设有两条消息A、B，A先发送但失败了在执行重试时，B发送且成功了，之后A也重试成功了，此时A、B消息顺序就反了，如果将此参数设置为1，则可以保证A在重试时，B消息无法进行发送，必须等A收到broker响应后B才能发送，设置较高可以提升吞吐量，但会占用更多的内存，此参数值
kafka笔记
分区应答，回复成功，则清除sender发送的数据以及分区器队列中的数据，失败则重试（次数不限）。原因说明：因为在kafka1.x以后，启用幂等后，kafka服务端会缓存producer发来的最近5个request的元数据，故无论如何，都可以保证最近5个request的数据都是有序的。有指定分区，按指
让代码变得优雅简洁的神器：Java8 Stream流式编程
流（Stream）是对数据进行连续处理的抽象概念，可以看作数一种迭代器，按步骤处理数据元素。流的创建方式包括从集合、数组、文件等数据源获取输入流或者输出流，或者通过网络连接获取到网络流，例如Kafka 的流处理。常见的使用场景包括从大型数据源读取、过滤、数据转换、聚合等操作。 并行流是指通过将
Kafka 安装及基本入门
Kafka 是一个开源的分布式消息引擎/消息中间件，同时Kafka也是一个流处理平台。Kakfa 支持以发布/订阅的方式在应用间传递消息，同时并基于消息功能添加了 Kafka Connect、Kafka Streams 以支持连接其他系统的数据源，如 ES、Hadoop 等。Kafka 最核心的最成
springboot kafka 实现延时队列
延时队列的技术实现方案有：redis延时队列，Kafka延时队列，rabbit延时队列，Kafka延时队列等本文章springboot kafka 实现延时队列，使用Kafka消费者的pause函数（暂停）和resume函数（恢复）+定时任务+事件监听机制+工厂。延时任务的应用场景：1，订单超时自动
【深入理解Kafka系列】 第二章 生产者
讲述生产者客户端的具体用法及整体架构。包括配置参数、消息的发送方式、序列化器、分区器、拦截器等。
手把手教你搭建zookeeper和kafka集群（超级详细）
手把手教你搭建zookeeper和kafka集群（超级详细）
Flink 从 kafka 中读取数据并输出到 kafka
Flink 从 kafka 中读取数据并输出到 kafka。FlinkKafkaConsumer（）和FlinkKafkaProducer （）介绍
【大数据技术】Spark+Flume+Kafka实现商品实时交易数据统计分析实战（附源码）
【大数据技术】Spark+Flume+Kafka实现商品实时交易数据统计分析实战（附源码）
Kafka的安装和使用（Windows中）
2.3.1.2在小黑窗3中输入.\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic topic_test001然后回车。在黑窗口
Kafka 入门篇（一）
初识 Kafka什么是 KafkaKafka 的基本术语Kafka 的特性（设计原则）Kafka 的使用场景Kafka 的消息队列点对点模式的消息队列发布-订阅模式的消息队列Kafka 系统架构核心 APIKafka 为何如此之快broker 端配置broker.idportzookeeper.co
FlinkSQL消费Kafka写入Hive表
flinkSQL消费kafka实时写入hive表
Kafka的命令行操作
每个分区多个副本的主节点编号，这个在集群中才会是其它值，这里是单机模式，值等于唯一副本编号。执行此命令后，再来新的数据，也会被继续消费，就和普通的消费者一样。如果想要读取历史数据，可以选择把主题中的数据全部读取出来。就是在刚才的光标下继续输入一个数据，再回车即可。：分区编号是0，代表只有一个分区，编
logstash配置kafka输入 无法获取kafka数据 报错
logstash 配置kafka 接入kafka 认证
kafka时间戳的详解及使用
Kafka从0.10.0.0版本起，在消息内新增加了个timestamp字段，在Kafka 0.10.1.0以前(不包含0.10.1.0)，对于一个Topic而言，其Log Segment是由一个.log文档和一个.index文档组合而成，分别用来存储具体的消息数据和对应的偏移量。
Windows下安装使用Kafka(使用Kafka内置的ZooKeeper)
Windows下安装使用Kafka(使用Kafka内置的ZooKeeper)
Flink sql 写ddl连接kafka
flink sql 连接kafka 的DDL语句和提交java.lang.NoClassDefFoundError: org/apache/kafka/clients/consumer/OffsetResetStrategy Recovery is suppressed by NoRestartBa
