关于flink接收kafka消息的代码能不能用python写

相关推荐 更多相似问题

• 关于flink接收kafka消息的代码能不能用python写 flinkkafkapython有问必答

  2021-08-16 15:59
  回答 1 已采纳 应该可以，不过通常使用scala语言进行编写
• 关于Flink接收Kafka流数据使用Table API和SQL处理的问题 flink有问必答

  2021-08-18 11:07
  回答 2 已采纳 你的包是不是导错了。删除你导入的包，把下面的包复制放你程序中。 import org.apache.flink.api.common.typeinfo.TypeInformation; import
• flink消费kafka数据延迟 flinkpostgresqlscala有问必答

  2022-01-28 09:47
  回答 1 已采纳 那最后写入到库了吗，如果写不进去，上游kafka肯定会延迟越来越大的，可以在sink里多打印下错误，或者设置写入超时时间，问题应该在写入
• python flink kafka_Flink with Kafka

  2020-12-29 07:31
  嘿bro的博客 How Apache Flink manages Kafka consumer offsetsStep 1：例子：一个kafka topic，有两个partition，每个含有"A,B,C,D,E"信息。offset从0开始。Step 1Step 2:第二步，kafka consumer开始从partition 0开始读取信息...
• pylink链接kafka资源jar包flink-connector-kafka_2.12-1.11.0

  2020-12-04 15:12
  flink-connector-kafka_2.12-1.11.0.jar pylink链接kafka资源jar包f
• 没有解决我的问题, 去提问