当前位置:网站首页>Excuse me, when using Flink SQL sink data to Kafka, the execution is successful, but there is no number in Kafka
Excuse me, when using Flink SQL sink data to Kafka, the execution is successful, but there is no number in Kafka
2022-07-07 14:02:00 【Alibaba cloud Q & A】
Excuse me, , In the use of flink sql sink Data to kafka When the implementation is successful , however kafka There's no data , How to solve this problem ?
Take the answer 1:
Add a after the execution print().
This answer comes from the nail group “【2】Apache Flink China Community ”
边栏推荐
- Clickhouse (03) how to install and deploy Clickhouse
- 566. Reshaping the matrix
- Flask session forged hctf admin
- 现在网上开户安全么?那么网上开户选哪个证券公司?
- Talk about pseudo sharing
- call undefined function openssl_cipher_iv_length
- Drawerlayout suppress sideslip display
- Vmware 与主机之间传输文件
- The delivery efficiency is increased by 52 times, and the operation efficiency is increased by 10 times. See the compilation of practical cases of financial cloud native technology (with download)
- Excerpt from "misogyny: female disgust in Japan"
猜你喜欢

10 pictures open the door of CPU cache consistency

室內ROS機器人導航調試記錄(膨脹半徑的選取經驗)
![SSRF漏洞file伪协议之[网鼎杯 2018]Fakebook1](/img/10/6de1ee8467b18ae03894a8d5ba95ff.png)
SSRF漏洞file伪协议之[网鼎杯 2018]Fakebook1

AutoCAD - how to input angle dimensions and CAD diameter symbols greater than 180 degrees?

. Net core about redis pipeline and transactions

Sliding rail stepping motor commissioning (national ocean vehicle competition) (STM32 master control)

Leecode3. Longest substring without repeated characters

"Song of ice and fire" in the eleventh issue of "open source Roundtable" -- how to balance the natural contradiction between open source and security?

Navicat运行sql文件导入数据不全或导入失败

2022-7-6 sigurg is used to receive external data. I don't know why it can't be printed out
随机推荐
Help tenants
call undefined function openssl_ cipher_ iv_ length
Custom thread pool rejection policy
Build a secure and trusted computing platform based on Kunpeng's native security
Problems that cannot be accessed in MySQL LAN
[daily training -- Tencent select 50] 231 Power of 2
[daily training] 648 Word replacement
118. Yanghui triangle
[1] ROS2基础知识-操作命令总结版
Introduction to database system - Chapter 1 introduction [conceptual model, hierarchical model and three-level mode (external mode, mode, internal mode)]
Huawei image address
Clickhouse (03) how to install and deploy Clickhouse
Ogre introduction
Split screen bug notes
高等数学---第八章多元函数微分学1
566. Reshaping the matrix
Flask session forged hctf admin
Leetcode simple question sharing (20)
Help tenants
THINKPHP框架的优秀开源系统推荐