Flink Kafka连接器
我使用的是kafkaconsumer82和连接器jar版本为0.10.2，kafka版本为0.9.1，flink版本为1.0.0。
当我在IDE中作为独立的主程序运行Java消费者时，它工作得很好。但是当我从flink run运行它时，我不会看到正在使用的消息，也不会看到1ocalhost:8081中JobManager的stdout中的任何日志。请告诉我可能有什么问题。
共有1个答案
作为第一步，我建议让版本同步。如果您使用的是Kafka0.9和Flink1.0.0，我建议使用flink-connector-kafka-0.9版本1.0.0，它包含FlinkkafkaConsumer09。
-
大家好，我正在努力将一个简单的avro模式与模式注册表一起序列化。 设置： 两个用java编写的Flink jobs（一个消费者，一个生产者） 目标：生产者应该发送一条用ConfluentRegistryAvroSerializationSchema序列化的消息，其中包括更新和验证模式。 然后，使用者应将消息反序列化为具有接收到的模式的对象。使用。 到目前为止还不错：如果我将架构注册表上的主题配置
-
Presto与Cassandra/ScylLadb的默认连接数是多少？如何设置此属性？谢谢
-
**dataframe2:从另一个来源获得的键的Dataframe（这些键是上表中ID列的分区键）-此表中不同键的数量约为0.15万** 现在，此代码总是导致“com.datastax.oss.driver.api.core.servererrors.ReadFailureException：在一致性LOCAL_ONE读取查询期间Cassandra失败（需要1个响应，但只有0个副本响应，1个失败）
-
代码片段如下所示： 如果有人有决议，请帮忙？
-
kafka jdbc接收器连接器是否支持将其使用的内容写入不同的主题。我正在寻找一种传递机制，如下图所示。如果没有，我可以链接一个接收器和源（从接收器写的地方读取），但我认为这不会有那么好的性能。也许我可以修改现有的接收器连接器来实现这一点？
-
本文向大家介绍HTTP长连接、短连接？相关面试题，主要包含被问及HTTP长连接、短连接？时的应答技巧和注意事项，需要的朋友参考一下 在HTTP/1.0中默认使用短连接。也就是说，客户端和服务器每进行一次HTTP操作，就建立一次连接，任务结束就中断连接。当客户端浏览器访问的某个HTML或其他类型的Web页中包含有其他的Web资源（如JavaScript文件、图像文件、CSS文件等），每遇到这样一个W
-
问题内容： 我在两个表之间有多对多关系。 表包含我的餐厅。 表包含不同的类别。 表包含两列，每列分别包含两个表的ID。 以下陈述是我能想到的，但没有给我我想要的输出。 我希望输出是有关餐厅的信息，并在最后一列中是类别的连接行。 问题答案： 要串联值，可以使用。xml路径解决方案有误，应使用和特殊字符。 您也可以使用变量解决方案
-
有人能告诉我在maven中scm连接和developerConnection之间的区别吗？ 我正在尝试使用，它需要其中之一。 [错误]未能执行goal org . Apache . maven . plugins:maven-release-plugin:2 . 3 . 2:在项目was-topology-legacy-dsl上准备(default-cli ):缺少必需的设置:必须指定scm连接或