尝试将Flink 1.9 SQL-Client与Kafka一起使用，但未成功。在弄清楚所需的jar文件并将它们复制到lib目录后，当执行SELECT * FROM table-name时，我得到了以下运行时异常： Flink SQL> select * from default_catalog.default_database.member_customer_newsletters/lib/flink-sql-connector-kafka-0.11_2.12-1.9.0.jar
浏览 231提问于2019-09-20得票数 0
虽然我已经导入了org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer011，但是我得到了以下错误。FlinkKafkaProducer011() {
public static class NextTransactionalIdHint extends org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer.NextTransactionalIdHintKafk
浏览 5提问于2020-08-11得票数 0
回答已采纳
当我试图在我的build.sbt文件中添加flink连接器-kafka包时，我会看到一个错误，它不能解决它。val flinkVersion = "1.4.1" "org.apache.flink" %% "flink-scala" % flinkVersion% "provided",
"org.apache.flink" %% &
浏览 2提问于2018-03-03得票数 2
回答已采纳
我以为所有的Java依赖都是和pip install apache-flink一起安装的 以上错误发生在该行上： kafka_consumer = FlinkKafkaConsumer( deserialization_schema=deserialization_schema, 'bootstrap.servers': KAFKA_BOOTSTRAP_SERVERS}) 根据错误，我是否需要在pyflink环境中通过下载并添加
浏览 252提问于2021-09-26得票数 0
flink Dockerfile：
ADD http://central.maven.org/maven2/org/apache/flink/flink-connector-kafka_2.12/1.7.2/flink-connector-kafka_2.12-1.7.2.jar /opt/flink
浏览 0提问于2019-04-12得票数 1
回答已采纳
在Flink SQL上使用带有Kerberos身份验证的Kafka数据源，Flink的本地测试已经通过，但当我将任务推到纱线上时，错误消息提示无法找到Kafka的JAAS文件！报告以下错误 at org.apache.flink</
浏览 23提问于2022-01-24得票数 1
我使用flink流和flink-连接器- kafka来处理kafka的数据。Fetched offset -1, timestamp -1
<dependenc
浏览 6提问于2020-04-15得票数 0
回答已采纳
[] - The reporter factory (org.apache.flink.metrics.kafka.KafkaReporterFactory) could我的flink conf文件：
metrics.reporter.kafka.factory.class: org.apache.flink.metrics.kafka.KafkaReporterFactorymetrics.reporter.kafka.class: org.apache.fl
浏览 10提问于2021-08-25得票数 2
回答已采纳
;import org.apache.flink.streaming.util.serialization.SimpleStringSchema4.0.0.xsd"> <groupId>com.dataartisans</groupId>
浏览 21提问于2020-01-23得票数 0
回答已采纳
4回答
与卡夫卡连接的Flink
、、、
环境：Flink 1.1.3我正在尝试将flink与kafka (Flink 1.1.3 Kakfa 0.10.1.1)连接起来，> <version>1.3-SNAPSHOT</version:f
浏览 5提问于2017-02-09得票数 0
我使用的是最新的Flink-1.1.2-Hadoop-27和flink-连接器-kafka-0.10.2-Hadoop 1罐。Flink消费者如下： properties = new Properties();
InputStream props = Resources.getResource(KA
浏览 2提问于2016-10-14得票数 7
回答已采纳
我正在使用Flink Connector Kafka 1.8.0。(取决于kafka-clients 2.0.1) https://mvnrepository.com/artifact/org.apache.flink/flink-connector-kafka_2.12/1.8.0 使用gradle： // https://mvnrepository.com/artifact&
浏览 23提问于2019-12-26得票数 0
我正在尝试使用Scala和Flink将消息发布到Kafka主题中。但是，当使用中提供的代码创建FlinkKafkaProducer对象时，它告诉我无法应用构造器。._[error] (x$1: String,,x$4
浏览 103提问于2021-05-24得票数 1
我正在尝试连接到本地机器上的Kafka (2.1)，并在随Flink (1.7.2)附带的shell中阅读。我正在做的事情是：:require flink-connector-kafka-base_2.11-1.7.1.jar
import org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsu
浏览 0提问于2019-03-11得票数 1
回答已采纳
下面是使用Flink和Kafka的例子。我只找到像this page这样的结果，它们不能正确编译，并且给出了很难查找的错误消息。org.apache.flink.streaming.util.serialization.SimpleStringSchema;
import org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer011', name: 'flink-core', versio
浏览 170提问于2019-05-24得票数 2
回答已采纳
我正在编写一个如下所示的Flink Kafka集成程序，但是得到了kafka的超时错误：import org.apache.flink.streaming.connectors.kafkastream.addSink(kafkaProducer)
}从
浏览 6提问于2017-12-15得票数 0
我正在使用flink和kafka，我得到了这个错误。(FlinkKafkaConsumer.java:695) at org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer082)
浏览 2提问于2016-06-30得票数 4
我正在集成Flink 1.8流和kafka 2.x(kafka_2.12-2.2.0，kafka_2.12-2.3.0)，并在启动flink作业几秒钟后遇到异常：
<
浏览 239提问于2019-07-23得票数 0
我仍然不能清楚地理解并行性，比方说，我们有一个flink集群，它有足够的插槽。在我们的flink工作中，我们从3个不同的kafka集群中使用3个kafka主题，每个主题有10个分区。
浏览 0提问于2019-03-13得票数 12
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
