一、启动Kafka集群和flink集群 环境变量配置（注：kafka 3台都需要设置，flink仅master设置就好） [root@master ~]# vim /etc/profile 配置完执行命令： [root@master ...

本文分享主要是ClickHouse的数据导入方式，本文主要介绍如何使用Flink、Spark、Kafka、MySQL、Hive将数据导入ClickHouse，具体内容包括： 使用Flink导入数据 使用Spark导入数据 从Kafka中导入数据 从MySQL中导入数据 ...

Kafka整合Flink使用----使用Flink消费kafka内的数据 添加依赖（代码参照kafka官网：https://kafka.apache.org/） kafka作为Flink的数据源 使用Flink消费kafka内的数据 ...

在消息RabbitMQ时,我们关心的一个问题是手动ack还是自动ack,如果是自动ack就怕出现丢消息的情况 Flink以RabbitMQ作为Source,是怎么保证消息唯一性的呢,是怎么保证ack的. 首先引入依赖包 <dependency> ...

https://www.cnblogs.com/huxi2b/p/7456936.html ...

经常遇到这样的场景,13点-14点的时候flink程序发生了故障,或者集群崩溃,导致实时程序挂掉1小时,程序恢复的时候想把程序倒回13点或者更前,重新消费kafka中的数据. 下面的代码就是根据指定时间戳(也可以换算成时间)开始消费数据,支持到这样就灵活了,可以在启动命令中加个参数,然后再 ...

前提： 1.配置flink的元数据到hive，不然每次重启flink-cli，之前建的表都丢失了 在这个默认的sql-client-defaults.yaml修改 catalogs: 　　- name: catalog_1 　　type: hive 　　hive ...

因业务要求，我们需要从Kafka中读取数据，变换后最终Sink到业务的消息队列中，为保证数据的可靠性，我们同时对Sink的结果数据，进行保存。最终选择将流数据Sink到HDFS上，在Flink中，同时也提供了HDFS Connector。下面就介绍如何将流式数据写入HDFS，同时将数据 ...