我在试着干涉kafka和flink。其思想是使用kafka队列并使用flink转换数据。我正在遵循下面提到的示例
另外，我在项目中加入了kafka和flink类，如下所示。此代码在tomcat中部署的war文件中运行。
当运行这段代码时，我得到以下错误。Unrecoverable error java.util.concurrent.Complet
浏览 4提问于2017-12-12得票数 1
回答已采纳
我试图让Apache项目与Apache 1.0.0集成。当我试图在我的build.sbt文件中添加flink连接器-kafka包时，我会看到一个错误，它不能解决它。然后，当我查看maven存储库中可用的选项时，对于0.10.2以上的任何版本，Apache 2.11-1.0.0都不存在maven依赖关系。% "provided",
"org.apache.flink" %
浏览 2提问于2018-03-03得票数 2
回答已采纳
1回答
我正在尝试将Flink与Kafka集成，并读取Kafka producer的数据。我尝试按照flink-docs-release-1.11文档中的代码运行以下代码 import java.util.Properties;import org.a
浏览 23提问于2021-02-11得票数 0
我正在尝试使用flink从kafka流数据。我的代码编译时没有出错，但在运行时我得到了以下错误： org/apache/flink/strea
浏览 2提问于2017-10-09得票数 4
回答已采纳
1回答
我正在尝试将Apache Kafka 2.11-0.10.0.0与Apache Flink 1.1.2集成。我正在使用scala-shell对其进行测试，并得到以下错误。找不到类org.apache.flink.streaming.api.checkpoint.CheckpointNotifier i
浏览 13提问于2016-09-15得票数 1
回答已采纳
我们有几个阅读卡夫卡主题的flink应用程序，它们工作得很好。但最近，我们向现有的flink作业添加了一个新主题，它在启动时立即开始失败，并出现以下根错误：
Caused by: org.apache.kafka.common.KafkaException: java.lang.NoClassDefFoundError将lz4依赖项直接添加到应用程序中不起作用，奇怪的是，它在本地运行良好，但在远程集群上失败。flink运行时版本是1.
浏览 5提问于2020-07-31得票数 1
回答已采纳
1回答
例如，我想测试卡夫卡/ Flink与FlinkKafkaConsumer011和FlinkKafkaProducer011的集成。这一进程将是：
谢谢!
浏览 0提问于2018-04-16得票数 3
作为PyFlink pipeline.classpath配置的一部分传递的类加载类与将它们放入$FLINK_HOME\lib目录之间有什么区别？当我想使用flink-sql-connector-kafka-*.jar时，只要使用pipeline.classpath传递它就可以了，但是当我想使用一些具有一些外部依赖项的东西时，比如需要avro-*.jar jars的flink-avro-*.jar。它
浏览 15提问于2022-01-24得票数 0
回答已采纳
我正在编写一个如下所示的Flink Kafka集成程序，但是得到了kafka的超时错误：import org.apache.flink.streaming.connectors.kafkastream.addSink(kafkaProducer)
env.execute("Flink kafka
浏览 6提问于2017-12-15得票数 0
1回答
我们正在使用一个集成平台来部署Kafka。我们使用模式注册表来存储模式。是否可以将模式注册中心与flink集成？如何从汇流平台读取AVRO格式的数据？
浏览 8提问于2022-06-17得票数 0
回答已采纳
更新当识别压缩类型时，尝试将LZ4与运行时由于某种原因可以找到的KafkaLZ4BlockInputStream相关联。作业，用来消费卡夫卡的唱片。在将JAR文件提交给Flink之后，任务管理器说缺少KafkaLZ4BlockInputStream类： ...
浏览 18提问于2021-12-09得票数 1
我们在生产环境中有一个安全的Kafka集群(使用TLS加密、基于证书的客户端身份验证和ACL)。我正在尝试弄清楚如何使用适当的设置配置Flink Kafka连接器，以便它可以安全地连接到我们的Kafka集群。Flink可以做到这一点吗？我是否必须通过属性传递安全配置内容？我们的Flink集群运行在Kubernetes (1.14.2)上，并使用最新的Fli
浏览 39提问于2019-08-14得票数 1
虽然我已经导入了org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer011，但是我得到了以下错误。Too many arguments for constructor FlinkKafkaProducer011这是IDE的定义。FlinkKafkaProducer011() {
public static class
浏览 5提问于2020-08-11得票数 0
回答已采纳
1回答
我正在尝试创建一个简单的Flink Kafka消费者16:47:28,451 INFO org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer09INFO org.apache.
浏览 11提问于2019-07-13得票数 1
尝试将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
浏览 231提问于2019-09-20得票数 0
我的生产代码运行得很好，但是我的集成测试抛出了SecurityProtocol的ClassNotFoundException。我使用的是spring-boot-parent 1.5.10.RELEASE。我得到了一个不同的错误： <groupId>org.springframework.kafka</groupId>
<artifactId>spring-kafk
浏览 0提问于2018-02-16得票数 6
回答已采纳
说我们不应该同时升级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
回答已采纳
2回答
我感兴趣的是有什么方法可以实现CEP(复杂事件处理)系统来进行监控。我需要监视许多设备，并且需要使用事件过滤器比较结果。
有没有针对这种特殊情况的现代架构？
浏览 21提问于2016-07-18得票数 0
下面是我正在尝试的高级用例。我们有发布到Kafka主题的学生数据流，我们的模块必须以流的形式读取学生ids，并从多个来源获取每个学生的关联数据，然后为每个学生执行一些计算，并将每个学生的关联计算发布到kafka主题中。因此，这里的问题是更好地编写一个大的Spark作业或使用Akka为每个源提供单独的服务，以便参与者可以并行工作，获取一堆学生it，并从各自的源获取数
浏览 2提问于2017-07-14得票数 1
在过去的一个月里，我一直在学习卡夫卡，尽管它们是关于这个主题的许多文章和视频--我仍然无法准确地理解一旦处理得足够好。让我总结一下我迄今所理解的：
Kafka流可以用于进行一些ETL或Analytics --这意味着我们可以编写能够进行数据丰富和转换的Java代码，并将其插入卡夫卡自身？，以便实现精确的一次处理。在卡夫卡消费者生产者API中，只有当我们从一个主题读取消息，然后在同一集群中写入另一个主题时，才有可能实现这一目的。这将适用于Kafka事务(
浏览 2提问于2022-10-04得票数 0
云服务器
ICP备案
实时音视频
对象存储
云直播
腾讯云开发者
