当我们在作为SQL Server数据库表的源的Flink SQL CLI中选择任何表时，为什么Flink作业在从数据库表中获取所有记录后“完成”？
浏览 4提问于2020-12-25得票数 1
我使用flink流和flink-连接器- kafka来处理kafka的数据。Fetched offset -1, timestamp -1
<
浏览 6提问于2020-04-15得票数 0
回答已采纳
说我们不应该同时升级Flink和Kafka连接器版本。
但是我不能用旧版本的卡夫卡连接器与更新的Flink。我尝试使用Flink -连接器-kafka-010 1.10.2和Flink 1.14，并获得异常：java.lang.NoSuchMethodError: org.apache.flink.api.common.state.OperatorStateStore.getSerializableListState
浏览 12提问于2022-08-31得票数 0
回答已采纳
我们正在考虑使用Flink SQL对过去5- 10分钟内的实时kafka数据进行即席分析。为了实现这一点，我们似乎需要扩展Kafka连接器，使其只在给定的时间段内读取消息，并使用它来生成有限的输入源。 我想知道在这方面是否有其他方法。任何建议都将非常受欢迎。
浏览 12提问于2019-02-16得票数 0
我们在生产环境中有一个安全的Kafka集群(使用TLS加密、基于证书的客户端身份验证和ACL)。我正在尝试弄清楚如何使用适当的设置配置Flink Kafka连接器，以便它可以安全地连接到我们的Kafka集群。Flink可以做到这一点吗？我是否必须通过属性传递安全配置内容？我们的Flink集群运行在Kubernetes (1.14.2)上，并使用最新的Flink稳定版本(v1.8)和集成的kafka连接器。
浏览 39提问于2019-08-14得票数 1
我想使用Flink对Postgresql中的数据进行一些分析。我应该如何和在哪里给出端口地址，用户名和密码。我正在尝试使用链接：中提到的表源。
浏览 0提问于2018-06-21得票数 1
回答已采纳
我添加了在上可用的flink-sql连接器。有人能帮我举个合适的例子来做这个吗？/flink-sql-connector-kafka_2.11-1.10.1.jar")
deserialization_schema = SimpleStringSchema()/venv/lib/python3.8/site-packages/pyflink/datastream/connectors.py", line 186,
浏览 23提问于2022-02-03得票数 0
我正在使用集群、Schema服务，并试图在Flink作业中处理Debezium消息。作业被配置为使用Table & SQL连接器和Confluent格式。表连接器配置 " ORDER_ID STRING,\n" +
"'<CLOUD_BOOTSTRAP_SERVER_ENDPOINT>:9092',
浏览 3提问于2021-02-08得票数 3
当我试图在我的build.sbt文件中添加flink连接器-kafka包时，我会看到一个错误，它不能解决它。val flinkVersion = "1.4.1" "org.apache.flink" %% "flink-scala" % flinkVersion% "provided",
"org.apache.flink&q
浏览 2提问于2018-03-03得票数 2
回答已采纳
;import org.apache.flink.streaming.util.serialization.SimpleStringSchema4.0.0.xsd"> <groupId>com.dataartisans</groupId>
浏览 21提问于2020-01-23得票数 0
回答已采纳
我想知道，Apache (v1.11)是否可以通过使用Table/SQL end-to-end-exactly-once 实现内置连接器 (Kafka，JDBC，)
我在文档里找不到任何关于这个的东西。
浏览 2提问于2020-12-02得票数 1
回答已采纳
我使用Flink 1.7.2编写了一个简单的字数统计应用程序，同时使用Kafka 2.2作为消费者和生产者。taskexecutor日志中的一部分，该日志不断重复：2019-07-05 14:05:47,552 INFO org.apache.flink</em
浏览 37提问于2019-07-05得票数 0
回答已采纳
4回答
与卡夫卡连接的Flink
、、、
环境：Flink 1.1.3我正在尝试将flink与kafka (Flink 1.1.3 Kakfa 0.10.1.1)连接起来，> <version>1.3-SNAPSHOT</version;
impo
浏览 5提问于2017-02-09得票数 0
我们希望在读取来自kafka的消息时实现并行性。因此，我们希望在flinkkafkaconsumer中指定分区编号。它将读取kafka中所有分区的消息，而不是特定的分区号。
浏览 139提问于2020-07-09得票数 1
我以为所有的Java依赖都是和pip install apache-flink一起安装的 以上错误发生在该行上： kafka_consumer = FlinkKafkaConsumer( deserialization_schema=deserialization_schema, 'bootstrap.servers': KAFKA_BOOTSTRAP_SERVERS}) 根据错误，我是否需要在pyflink环境中通过下载并添加
浏览 252提问于2021-09-26得票数 0
是否可以在Apache Flink 1.2.0中运行elasticsearch 5.x版？我无法将Flink升级到1.3，因为我需要1.2.0版本才能运行kafka。根据这个链接中所说的：这个连接器应该可以工作(因为我的Flink
浏览 5提问于2017-02-18得票数 0
回答已采纳
IBM MQ -> Kafka连接-> Flink -> MongoDBIBM MQ部件是不能更改的遗留组件。可能会使用confluent或cloudera平台来容纳流程中的Kafka和Flink部分。
我可以使用一些关于上述方法的想法/建议。
浏览 2提问于2019-02-23得票数 0
我对Flink，Kafka和Elastic Search的不同版本有问题。我使用的是Flink 1.8.1版本，但我不知道该使用哪个版本的Kafka。另一方面，我想使用版本6进行弹性搜索。你认为哪些版本适合Flink，Kafka和Elastic Search？下面的链接是Kafka的一个版本，但在评论部分，它是作为测试版enter link description here介绍的
浏览 9提问于2019-12-24得票数 2
2回答
我正在开发一个沉入Kafka的Flink应用程序。我创建了一个默认池大小为5的Kafka生产者。这是kafka生产者池大小或检查点的问题吗？.java:934) at org.apache.flink.streaming.
浏览 7提问于2020-03-21得票数 1
云服务器
ICP备案
对象存储
实时音视频
云直播
腾讯云开发者
