sink云消息队列 Kafka 版的相关内容

问答 2022-08-09 来自：开发者社区

mysql的datetime类型数据sink到kafka就自动变成时间戳了，这个有什么办法解决吗？

问答 2022-07-07 来自：开发者社区

各位你们在使用flink sql sink数据到kafka的时候出现执行成功，但是kafka里面没有

各位你们在使用flink sql sink数据到kafka的时候出现执行成功，但是kafka里面没有数据的情况？

问答 2022-07-07 来自：开发者社区

请问，在使用flink sql sink数据到kafka的时候出现执行成功，但是kafka里面没有数

请问，在使用flink sql sink数据到kafka的时候出现执行成功，但是kafka里面没有数据，这个怎么解决？

问答 2022-06-21 来自：开发者社区

sink端一般都自己定义么 source ->kafka. kafka->sink 怎么保证一致性呢

如题

文章 2022-04-06 来自：开发者社区

Flink的sink实战之二：kafka

欢迎访问我的GitHub这里分类和汇总了欣宸的全部原创(含配套源码)：https://github.com/zq2599/blog_demos版本和环境准备本次实战的环境和版本如下：JDK：1.8.0_211Flink：1.9.2Maven：3.6.0操作系统：macOS Catalina 10.15.3 （MacBook Pro 13-inch, 2018）IDEA：2018.3.5 (Ult....

问答 2021-12-07 来自：开发者社区

sink失败不消费kafka消息怎么办？

大家好，我现在有个疑问目前我使用kafka作为source，经过计算以后，将结果sink到数据库；后来日志数据库发生了timeout或者宕机，kafka这边的主题，却消费掉了造成了数据丢失，那么如何设置才可以确认在sink失败的时候，不提交kafka的消费位移呢？多谢大家了 *来自志愿者整理的flink邮件归档

问答 2021-12-07 来自：开发者社区

单流的一条数据，需要先sink 至mysql，再sink至kafka，并保证两sink的原子性以及s

请问下，有没有大佬做过类似的事情？另外，flink side out功能，可以将单流分成多流，但是不是分成多流后，但两条流sink的时候，是不是没法保证sink时候的时序？ *来自志愿者整理的flink邮件归档

问答 2021-12-07 来自：开发者社区

flink sink kafka过慢问题

我在使用flink处理数据写入kafka的过程中，写入kafka的速度过慢，导致数据高峰期数据有堆积，在数据达到每秒11000条的时候就开始堆积，处理逻辑很简单，就有坐标点经纬度转换成省市区，其他逻辑不复杂， sink端kafka 6个分区，source端kafka6个分区，每天在晚高峰的时候会堆积30分钟，有没有办法大幅度提高写入能力，难道只能加大kafka的分区吗？ flink sub.....

问答 2021-12-06 来自：开发者社区

flink sink到kafka

大家好，我想通过avro格式sink到kafka,请问该怎么实现，官网上没找到相关方法。 *来自志愿者整理的flink邮件归档

问答 2021-12-06 来自：开发者社区

单流的一条数据，需要先sink 至mysql，再sink至kafka，并保证两sink的原子性以及s

单流的一条数据，需要先sink 至mysql，再sink至kafka，并保证两sink的原子性以及sink顺序，是否可以做到？请问下，有没有大佬做过类似的事情？另外，flink side out功能，可以将单流分成多流，但是不是分成多流后，但两条流sink的时候，是不是没法保证sink时候的时序？ *来自志愿者整理的flink邮件归档