java

Flink 从入门到实战

网友分享 • 数栈君发表了文章 • 0 个评论 • 8 次浏览 • 2 天前 • 来自相关话题

Flink中的批和流批处理的特点是有界、持久、大量，非常适合需要访问全部记录才能完成的计算工作，一般用于离线统计。流处理的特点是无界、实时, 无需针对整个数据集执行操作，而是对通过系统传输的每个数据项执行操作，一般用于实时统计。一个无界流可以分解为多个有界流... ...查看全部

【Rabbitmq篇】RabbitMQ⾼级特性----持久性，发送⽅确认，重试机制

网友分享 • 数栈君发表了文章 • 0 个评论 • 10 次浏览 • 2 天前 • 来自相关话题

一.持久化我们在前⾯讲了消费端处理消息时,消息如何不丢失,但是如何保证当RabbitMQ服务停掉以后,⽣产者发送的消息不丢失呢.默认情况下, RabbitMQ 退出或者由于某种原因崩溃时,会忽视队列和消息,除⾮告知他不要这么做.它确保消息在消息队列崩溃、重启或... ...查看全部

Kafka学习-Java使用Kafka

网友分享 • 数栈君发表了文章 • 0 个评论 • 9 次浏览 • 2 天前 • 来自相关话题

一、Kafka1、什么是消息队列假设我们有两个服务：生产者A每秒能生产200个消息，消费者B每秒能消费100个消息。那么B服务是处理不了A这么多消息的，那么怎么使B不被压垮的同时还能处理A的消息呢，我们引入一个中间件，即Kafka。（当然着并不能使消费者的处理... ...查看全部

如何解决MQ的重复消费问题？Kafka、ActiveMQ、RabbitMQ有什么区别？

网友分享 • 数栈君发表了文章 • 0 个评论 • 11 次浏览 • 2 天前 • 来自相关话题

如何解决MQ的重复消费问题？MQ（消息队列）的重复消费问题是一个需要认真对待的挑战，因为它可能导致业务逻辑的重复执行，进而引发数据不一致或其他问题。以下是一些常见的解决MQ重复消费问题的方法：一、确保消息幂等性消费者幂等设计：设计消费者时，应确保其具有幂等性，... ...查看全部

Apache Kudu 从 Flink 下沉数据到 Kudu

技术共享 • 数栈君发表了文章 • 0 个评论 • 161 次浏览 • 2024-11-05 14:45 • 来自相关话题

实现思路将数据从 Flink 下沉到 Kudu 的基本思路如下：环境准备：确保 Flink 和 Kudu 环境正常运行，并配置好相关依赖。创建 Kudu 表：在 Kudu 中定义要存储的数据表，包括主键和列类型。数据流设计：使用 Flink 的 DataStr... ...查看全部

技术总监写的十个方法，让我精通了lambda表达式

网友分享 • 数栈君发表了文章 • 0 个评论 • 382 次浏览 • 2024-01-22 11:08 • 来自相关话题

前公司的技术总监写了工具类，对Java Stream 进行二次封装，使用起来非常爽，全公司都在用。我自己照着写了一遍，改了名字，分享给大家。一共整理了10个工具方法，可以满足 Collection、List、Set、Map 之间各种类型转化。例如将 Co... ...查看全部

史上最坑爹的Java代码：Hello, World！

知识百科 • 数栈君发表了文章 • 0 个评论 • 273 次浏览 • 2024-01-19 10:28 • 来自相关话题

Hello, World! Hello, World!是很多Java开发人员写的第一程序，可就是这第一个程序，就把我们华丽丽带到了沟里。 (其实也不怪咱们开发人员，主要是好多教材的第一个程序都是Hello, World!) 一日掉沟里，很多年还一直在沟里趴着，... ...查看全部

面试官：说一说你的第一个Java程序是怎么跑起来的？

知识百科 • 数栈君发表了文章 • 0 个评论 • 254 次浏览 • 2024-01-19 10:28 • 来自相关话题

MySQL 可以用 JavaScript 写存储过程了！——PROPAGATION_NESTED

知识百科 • 数栈君发表了文章 • 0 个评论 • 266 次浏览 • 2024-01-18 10:33 • 来自相关话题

MySQL 可以用 JavaScript 写存储过程了！——PROPAGATION_NEVER

知识百科 • 数栈君发表了文章 • 0 个评论 • 246 次浏览 • 2024-01-18 10:31 • 来自相关话题

我问一下问题，我使用chunjun执行向hdfs写数据的任务，local模式不报错，但是standalone模式就会报一个反序列化失败的问题

ChunJun • 匿名用户发起了问题 • 1 人关注 • 0 个回复 • 576 次浏览 • 2023-06-02 11:06 • 来自相关话题

请问chunjun yarn-session的模式运行任务，报错，应该怎么解决，flink的yarn session可以运行

ChunJun • 匿名用户发起了问题 • 1 人关注 • 0 个回复 • 478 次浏览 • 2023-06-02 11:05 • 来自相关话题

flinkcdc捕获mysql表数据变化日志，但是flinkUI上Bytes Received 为0，这是什么原因啊

ChunJun • 匿名用户发起了问题 • 1 人关注 • 0 个回复 • 660 次浏览 • 2023-06-02 11:00 • 来自相关话题

请问flink.1.12的使用chunjun什么版本，我以前安装成功但是现在总是报错

ChunJun • 匿名用户发起了问题 • 1 人关注 • 0 个回复 • 419 次浏览 • 2023-06-02 11:00 • 来自相关话题

请问下，这个fetchsize，在mysql jdbc生效吗？我们验证了，好像配置了不生效

ChunJun • 匿名用户发起了问题 • 1 人关注 • 0 个回复 • 490 次浏览 • 2023-06-02 10:59 • 来自相关话题

请教下这4个参数设置了没有生效抽取速度还是很快

ChunJun • 群内解答回复了问题 • 1 人关注 • 3 个回复 • 469 次浏览 • 2023-06-02 10:59 • 来自相关话题

请教下，chunjun写sql ，使用mysql 谓词不会下推吗，就是where条件不会到数据库中执行吗？

ChunJun • 群内解答回复了问题 • 1 人关注 • 1 个回复 • 507 次浏览 • 2023-06-02 10:56 • 来自相关话题

双流join 维表的更新加载有没好的方案推荐

ChunJun • 匿名用户发起了问题 • 1 人关注 • 0 个回复 • 430 次浏览 • 2023-06-02 10:55 • 来自相关话题

请教下大家，这里明明已经成功的引入了这个 jar包，为什么老是报类这个不存在

ChunJun • 群内解答回复了问题 • 1 人关注 • 2 个回复 • 483 次浏览 • 2023-06-02 10:55 • 来自相关话题

请问下，当前达梦实时的connector支持吗？谢谢

ChunJun • 群内解答回复了问题 • 1 人关注 • 1 个回复 • 469 次浏览 • 2023-06-02 10:53 • 来自相关话题

Flink 从入门到实战

网友分享 • 数栈君发表了文章 • 0 个评论 • 8 次浏览 • 2 天前 • 来自相关话题

【Rabbitmq篇】RabbitMQ⾼级特性----持久性，发送⽅确认，重试机制

网友分享 • 数栈君发表了文章 • 0 个评论 • 10 次浏览 • 2 天前 • 来自相关话题

Kafka学习-Java使用Kafka

网友分享 • 数栈君发表了文章 • 0 个评论 • 9 次浏览 • 2 天前 • 来自相关话题

如何解决MQ的重复消费问题？Kafka、ActiveMQ、RabbitMQ有什么区别？

网友分享 • 数栈君发表了文章 • 0 个评论 • 11 次浏览 • 2 天前 • 来自相关话题

Apache Kudu 从 Flink 下沉数据到 Kudu

技术共享 • 数栈君发表了文章 • 0 个评论 • 161 次浏览 • 2024-11-05 14:45 • 来自相关话题

技术总监写的十个方法，让我精通了lambda表达式

网友分享 • 数栈君发表了文章 • 0 个评论 • 382 次浏览 • 2024-01-22 11:08 • 来自相关话题

史上最坑爹的Java代码：Hello, World！

知识百科 • 数栈君发表了文章 • 0 个评论 • 273 次浏览 • 2024-01-19 10:28 • 来自相关话题

面试官：说一说你的第一个Java程序是怎么跑起来的？

知识百科 • 数栈君发表了文章 • 0 个评论 • 254 次浏览 • 2024-01-19 10:28 • 来自相关话题

MySQL 可以用 JavaScript 写存储过程了！——PROPAGATION_NESTED

知识百科 • 数栈君发表了文章 • 0 个评论 • 266 次浏览 • 2024-01-18 10:33 • 来自相关话题

MySQL 可以用 JavaScript 写存储过程了！——PROPAGATION_NEVER

知识百科 • 数栈君发表了文章 • 0 个评论 • 246 次浏览 • 2024-01-18 10:31 • 来自相关话题

更多...

Flink 从入门到实战

【Rabbitmq篇】RabbitMQ⾼级特性----持久性，发送⽅确认，重试机制

Kafka学习-Java使用Kafka

如何解决MQ的重复消费问题？Kafka、ActiveMQ、RabbitMQ有什么区别？

Apache Kudu 从 Flink 下沉数据到 Kudu

技术总监写的十个方法，让我精通了lambda表达式

史上最坑爹的Java代码：Hello, World！

面试官：说一说你的第一个Java程序是怎么跑起来的？

MySQL 可以用 JavaScript 写存储过程了！——PROPAGATION_NESTED

MySQL 可以用 JavaScript 写存储过程了！——PROPAGATION_NEVER

我问一下问题，我使用chunjun执行向hdfs写数据的任务，local模式不报错，但是standalone模式就会报一个反序列化失败的问题

请问chunjun yarn-session的模式运行任务，报错，应该怎么解决，flink的yarn session可以运行

flinkcdc捕获mysql表数据变化日志，但是flinkUI上Bytes Received 为0，这是什么原因啊

请问flink.1.12的使用chunjun什么版本，我以前安装成功但是现在总是报错

请问下，这个fetchsize，在mysql jdbc生效吗？我们验证了，好像配置了不生效

请教下这4个参数设置了没有生效抽取速度还是很快

请教下，chunjun写sql ，使用mysql 谓词不会下推吗，就是where条件不会到数据库中执行吗？

双流join 维表的更新加载有没好的方案推荐

请教下大家，这里明明已经成功的引入了这个 jar包，为什么老是报类这个不存在

请问下，当前达梦实时的connector支持吗？谢谢

Flink 从入门到实战

【Rabbitmq篇】RabbitMQ⾼级特性----持久性，发送⽅确认，重试机制

Kafka学习-Java使用Kafka

如何解决MQ的重复消费问题？Kafka、ActiveMQ、RabbitMQ有什么区别？

Apache Kudu 从 Flink 下沉数据到 Kudu

技术总监写的十个方法，让我精通了lambda表达式

史上最坑爹的Java代码：Hello, World！

面试官：说一说你的第一个Java程序是怎么跑起来的？

MySQL 可以用 JavaScript 写存储过程了！——PROPAGATION_NESTED

MySQL 可以用 JavaScript 写存储过程了！——PROPAGATION_NEVER

话题描述

相关话题

1 人关注该话题