回答情况：
提问时间：
问题标签：
我正在尝试使用这个JSONKeyValueDeserializationSchema类测试一个Flink程序来读取来自Kafka的JSON数据。然而，我的Intellij找不到这个类。我的pom.xml <dependency> <artifactId<groupId>org.apache.flink
浏览 12提问于2016-09-02得票数 0
回答已采纳
我正在尝试将Apache Kafka 2.11-0.10.0.0与Apache Flink 1.1.2集成。我正在使用scala-shell对其进行测试，并得到以下错误。找不到类org.apache.flink.streaming.api.checkpoint.CheckpointNotifier import org.apache.flink.streaming.connectors.<
浏览 13提问于2016-09-15得票数 1
回答已采纳
我正在尝试使用以下代码从Kafka主题中获取JSON： public static void main(String[] args) throws@Override return "Kafkaand Flink says: " + value; });
浏览 2修改于2019-05-02得票数 3
回答已采纳
import org.apache.flink.streaming.api.scala.StreamExecutionEnvironmentimport org.apache.flink.formats.avro.AvroDeserializ
浏览 26提问于2021-08-18得票数 1
我们在生产环境中有一个安全的Kafka集群(使用TLS加密、基于证书的客户端身份验证和ACL)。我正在尝试弄清楚如何使用适当的设置配置Flink Kafka连接器，以便它可以安全地连接到我们的Kafka集群。Flink可以做到这一点吗？我是否必须通过属性传递安全配置内容？我们的Flink集群运行在Kubernetes (1.14.2)上，并使用最新的Flink稳定版本(v1.8)和集成的kafka连接器。
浏览 39提问于2019-08-14得票数 1
我正在尝试创建一个简单的Flink Kafka消费者16:47:28,448 INFO org.apache.kafka.common.utils.AppInfoParser- Kafka startTimeMs: 1563029248441
16:47:28,451 INFO org.apache.<em
浏览 11修改于2019-07-14得票数 1
说我们不应该同时升级Flink和Kafka连接器版本。
但是我不能用旧版本的卡夫卡连接器与更新的Flink。我尝试使用Flink -连接器-kafka-010 1.10.2和Flink 1.14，并获得异常：java.lang.NoSuchMethodError: org.apache.flink.api.common.state.OperatorStateStore.getSerializableListState(Ljava/lang/Strin
浏览 12提问于2022-08-31得票数 0
回答已采纳
我正在尝试从本地机器连接到Kafka：kafkaParams.setProperty它抛出以下错误：Caused by: org.apache.kafka.common.config.ConfigException: Invalid url in bootstrap.servers:以下是我的依赖项：
"org.apach
浏览 155修改于2016-07-26得票数 0
我正在使用Flink 1.11.2版本的Python Table API通过SASL协议连接到Kafka主题，但它失败了，错误如下。我在Flink java版本中尝试了相同的属性，并且我能够连接。Caused by: javax.security.auth.login.LoginException: unable to find LoginModule class: org.apache.kafka.common.security.plain.PlainLoginModule设置：
kafka = <em
浏览 9修改于2020-11-10得票数 0
我已经写了一个非常简单的Flink流作业，从卡夫卡使用FlinkKafkaConsumer082的数据。上的主题中放入一些东西时，它就会被我的Flink工作接收并处理。现在我试着看看如果我的Flink Job由于某种原因没有在线会发生什么。因此，我关闭了flink作业，并继续向Kafka发送消息。然后我再次开始我的Flink工作，并期望它能处理同时发送的消息。从我收集的FlinkKafkaConsumer082文档中可以看出，它自动负责与Kafka代理同步处理的偏移量。
浏览 0提问于2015-11-03得票数 2
我使用的KafkaConsumer82和连接器jar版本是0.10.2，kafka版本是0.9.1，flink版本是1.0.0。
当我在IDE中将Java使用者作为独立的主程序从运行时，它工作得很好。但是当我从flink run运行它时，我看不到使用的消息，也看不到1ocalhost:8081中JobManager的stdout中的任何日志。请让我知道可能是什么问题。
浏览 1修改于2016-05-09得票数 0
我的配置如下：
speStream.addSink(new FlinkKafkaProducer011(kafkaTopicName,new 场景1:
我在eclipse上写了一个flink作业(生产者)，它从文件夹中读取一个文件，并将msgs放在kafka主题上。例如， : --如果我放置一个记录为100条的文件，
浏览 0提问于2018-08-29得票数 2
回答已采纳
我对flink/Java/Scala相当陌生，所以这可能是一个没有问题的问题，但任何帮助都是值得赞赏的。我还没有找到一个使用Flink 1.13的Flink Kafka连接器的例子(并且为我工作)。[WARNING] Multiple versions of scala libraries detected
[ERROR] /hide/abs/path/github/flink-stuff/frauddetectionERRO
浏览 4修改于2021-07-19得票数 0
回答已采纳
我正在使用：
at org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer09.open(FlinkKafkaConsumer09at org.ap
浏览 1修改于2016-10-13得票数 0
如何设置一个单元测试环境，在这个环境中我可以创建Kafka主题，使用FlinkKafkaProducer对它们进行写入，并使用FlinkKafkaConsumer对它们进行读取？server.createTestTopic("my.test.topic", 1, 1)
server.shutdown() 但是这会抛出一个错误java.lang.NoClassDefFoundError: kafka
浏览 5提问于2020-08-03得票数 0
回答已采纳
我是Flink Stream processing的新手，需要一些Flink Kafka producer的帮助，因为经过一段时间的搜索后，找不到太多相关的东西。我目前正在从Kafka主题读取流，然后在执行一些计算后，我想将此写入Kafka中的一个新的独立主题。但我面临的问题是，我不能发送Kafka主题的密钥。我使用的是Flink Kafka连接器，它给了我FlinkKafkaConsumer和FlinkKafkaProducer。下面是我的代码，下面
浏览 46提问于2020-12-11得票数 0
回答已采纳
我正在使用Apache Flink，并尝试使用Apache Kafka协议连接到Azure eventhub以接收来自它的消息。我设法连接到Azure eventhub并接收消息，但我不能使用flink功能"setStartFromTimestamp(...)“如下所述()。当我试图从timestamp获取一些消息时，Kafka说broker端的消息格式是0.10.0之前的版本。有没有人遇到过这种情况？Apache Kafka客户端版本为2.0.1 Apache Flink版本
浏览 8修改于2019-03-22得票数 0
我尝试使用sasl机制(OAUTHBEARER)配置kafka身份验证(使用flink 1.9.2，kafka-client 2.2.0)。 at org.apache.flink.streaming.connectors.kafka.internal.KafkaPartitionDiscoverer.getAllPartitionsForTopics(KafkaPart
浏览 6提问于2021-09-06得票数 1
这项工作是使用卡夫卡连接器源(flink-连接器- Kafka -0.11)，我正在尝试分配时间戳和水印。我的代码非常类似于中的Scala示例。(AbstractFetcher.java:521)at org.apache.flink.streaming.connectors.<em
浏览 0修改于2018-03-06得票数 2
回答已采纳
我尝试提交简单的flink作业以接受来自kafka的消息，但提交作业后，在不到一分钟的时间内，作业失败，并出现以下kafka异常。我已经在我的本地机器上运行了kafka 2.12，并且我已经配置了这个作业所使用的主题。: The main method caused an error: org.apache.flink.client.program.ProgramInvocationException: Job failed(JobID: 5cc30fe72f685406126e2f5a26f10341)
浏览 170修改于2020-05-31得票数 0
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号