1回答
有没有办法在Flink中自动推断Kafka主题DDL而不需要手动CREATE TABLE查询，就像spark的情况一样。
浏览 21提问于2021-11-16得票数 1
我有一个非常简化的用例:我想使用Apache (1.11)从一个Kafka主题读取数据(让我们称之为source_topic)，计算其中的一个属性(称为b)，并将结果写入另一个Kafka主题(result_topic-1.11.2/lib/flink-sql-connector-kafka_2.11-1.11.2.jar")
CREATE TA
浏览 2提问于2020-11-16得票数 3
回答已采纳
我想使用Flink SQL将Kafka主题消费到表中，然后将其转换回DataStream。这是SOURCE_DDL CREATE TABLE kafka_source ( datetime TIMESTAMP(3), 'properties.group.id' = 'test-group',
&#
浏览 73提问于2021-03-30得票数 0
回答已采纳
我正在尝试读取Kafka主题中的记录，该主题是由kafka connect jdbc源连接器生成的，以下是连接器配置： "name": "customers", "poll.interval.mskafka读取主题的简单示例，并使用以下python代码再次将数据写入kafka： from pyflink.datastream import StreamExecution
浏览 670提问于2021-02-01得票数 0
回答已采纳
我有一个带有以下Avro IDL的Kafka主题，并注册到Schema Registry。myEntryType = "Type1"; MyEntry entry; } 为了阅读这个主题，我定义了以下DDL： CREATE TABLE my_table
`entry` ROW(`myEntryType` ROW(???))(KafkaFetcher.java:1
浏览 190提问于2021-10-12得票数 1
回答已采纳
1回答
为了说明起见，这是关于已定义的kafka接收器主题的输出：
通过尝试找出我阅读过的任何flink文档中的问题(此外，引用我可以在这个主题上找到的堆栈溢出问题(主要讨论Java实现).不用说，还没有解决。' """
t_env.execute_
浏览 6提问于2022-03-14得票数 0
我仍然不能清楚地理解并行性，比方说，我们有一个flink集群，它有足够的插槽。在我们的flink工作中，我们从3个不同的kafka集群中使用3个kafka主题，每个主题有10个分区。
浏览 0提问于2019-03-13得票数 12
回答已采纳
1回答
Kafka身份验证
、、、、
我只看过Pyflink表API中不包含连接建立()中的身份验证细节的kafka连接示例，即源表连接： CREATE TABLE source_table/lib_py/kafka-clients-2.4.1.jar")
env.add_jars("file:///opt/flink/lib_py/flink-connec
浏览 4提问于2021-11-12得票数 0
回答已采纳
我有一个要求建立聚合的数据，我们收到我们的Apache Kafka… 我有点不知道该走哪条技术路线…… 似乎人们看到的是标准的方式，一群Apache Kafka <-> Apache Spark <-> Solr Bitnami Data Platform 我找不到具体的例子说明这是如何工作的，但我也在问自己，是否有任何解决方案 Apache Kafka <-> Kafka Connect Solr此外，可能聚合mit Kafka <-> Kafka
浏览 34提问于2021-11-11得票数 0
场景: Apache Flink、Kafka、Protocol buffers data consumer。数据来源为协议缓冲区格式的Kafka主题(多个主题: topic#1、topic#3、topic#3)。使用者是Apache Flink使用者。每个主题都有一个独特的协议定义。中开发一个通用的数据摄取作业，将Kafka中的数据摄取到数据库中。如何为Apache Flink实现一个通用的protobuf反序列化器？我正在寻找实现将
浏览 13提问于2021-04-03得票数 0
例如，我有一个Flink表，如WITH ( 'flink.format'='raw',
'flink.properties.bootstrap.server
浏览 6提问于2022-05-07得票数 0
)flink-1.14.2zookeeper-3.7.0python 3.6.8- 760015705 ConsoleProducer- 31454 Kafkacdn_connector_ddl.pykafka_source_ddlimport kafka_sou
浏览 48提问于2022-01-14得票数 0
回答已采纳
我正在编写一个如下所示的Flink Kafka集成程序，但是得到了kafka的超时错误：import org.apache.flink.streaming.connectors.kafkastream.addSink(kafkaProducer)
}从
浏览 6提问于2017-12-15得票数 0
我们有几个阅读卡夫卡主题的flink应用程序，它们工作得很好。但最近，我们向现有的flink作业添加了一个新主题，它在启动时立即开始失败，并出现以下根错误： ... 7 more
我发现这个主题具有lz4压缩，并猜测flink由于某种原因无法使用它。flink运行时版本是
浏览 5提问于2020-07-31得票数 1
回答已采纳
背景时不时地，我们的Flink不能处理突发信息。如果我们使用常规的Kafka用户，那么就像添加一个用户一样简单(假设我们有足够的Kafka分区)，并且Kafka将在所有用户之间重新分配主题分区。Flink Kafka消费者自己管理分区分配和偏移量，这允许只有一次
浏览 27提问于2019-11-14得票数 1
假设我有通过Kafka主题输入的数据，并将输出数据发送给Kafka主题，那么在什么情况下Flink能够比Kafka流更快地处理数据？至少说到花在消费和生产上的时间，我不会期望Flink比Kafka流更快。
浏览 3提问于2022-08-09得票数 0
问题
如果不可能，在Kafka和HD
浏览 0提问于2018-05-02得票数 5
回答已采纳
我的例子是消息，而不是流，但为了可伸缩性，我正在考虑将其插入Spark或Flink，但无法理解这些扩展:我的应用程序，当Spark/Flink的一部分读取了Kafka的一些数据，然后退出或继续阅读吗？那么，Spark/Flink将如何决定他们必须生成更多的我的应用程序实例来提高吞吐量呢？
谢谢!
浏览 4提问于2017-09-20得票数 0
回答已采纳
云服务器
对象存储
ICP备案
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号