那些遇到过的问题

小编Kes*_*dhi的帖子

如何使用 kafka 控制台生产者发送键值消息

我有一个用例，我需要使用 Kafka Console Producer 发送键值消息。那么如何通过Kafka Console Producer命令来实现呢？

apache-kafka kafka-consumer-api kafka-producer-api

Kes*_*dhi
lucky-day
19
推荐指数
2
解决办法
2万
查看次数

Apache Flink to use S3 for backend state and checkpoints

Background

  • I was planning to use S3 to store the Flink's checkpoints using the FsStateBackend. But somehow I was getting the following error.

Error

org.apache.flink.core.fs.UnsupportedFileSystemSchemeException: Could not find a file system implementation for scheme 's3'. The scheme is not directly supported by Flink and no Hadoop file system to support this scheme could be loaded.
Run Code Online (Sandbox Code Playgroud)

Flink version: I am using Flink 1.10.0 version.

amazon-s3 checkpoint apache-flink checkpointing flink-streaming

Kes*_*dhi
lucky-day
1
推荐指数
1
解决办法
1618
查看次数

标签 统计

amazon-s3 ×1

apache-flink ×1

apache-kafka ×1

checkpoint ×1

checkpointing ×1

flink-streaming ×1

kafka-consumer-api ×1

kafka-producer-api ×1