如何在Amazon MSK中查看未交付的消息？
我正在浏览AWS的服务MSK，该服务是Kafka的管理服务。我想检查消费者从生产者发送后，消费者没有消耗多少邮件。 通过启用监视选项AWS提供的唯一方法是…
AWS MSK。 Kafka Connect - 插件类加载
我正在使用MSK中的Kafka Connect。 我已经定义了一个指向S3中的zip文件的插件 - 这可以正常工作。 我已经实现了 smt强>相同的存储夹和文件夹与插件的z…
Kafka 的 Confluence S3 Sink 连接器无法使用 MSK / MSK Connect 连接到 S3
我正在尝试使用Apache MSK / MSK连接和Confluent S3接收器连接器将KAFKA消息存储到S3。 当连接器试图达到S3时，我会遇到超时错误。 为了排除权限问题…
Kafka Mirrormaker 2.0 连接丢失后恢复缓慢
在两个群集之间的连接后，我们的Kafka Mirrormaker 2.0的恢复缓慢被终止并再次重新连接后，我们遇到了问题。 我们有2个kafka簇A和B，并且镜像在双向A…
亚马逊MSK未能将1秘密与集群相关联。提供的秘密有无效的模式
我们要设置。 我们在MSK中创建了一个群集， 也创建了一个秘密 Amazonmsk_testmsk2 ，并用键为 password and值为 {“ username”：“ alice”：“ alic…
Mirror-maker 2 不复制旧数据
我有 2 个 MSK kafka 集群 A 和 B 。我想使用 MM2 将数据从 A 复制到 B 。它复制新数据，但旧数据不会从 a 复制到 B 。 MM2 配置文件 - A.bootstrap.s…
如何在 C# 代码中使用 Amazon MSK 将消息发布到 Kafka
我正在创建 ac# 应用程序来向 Kafka 发布消息。在我的应用程序的当前版本中，我使用 docker（confluenceinc-cp 和 confluenceinc-zookeeper）在本地设…
AWS MSK Connect 以 Mongo DB 作为源
我们计划在 AWS 中创建一个 MSK，并使用 Mongo DB 作为 MSK 的源。我们没有看到任何用于连接到 Mongo DB 作为源的预定义连接器。 如何设置连接器？ 我…
在 EC2 上运行 kafka 消费者
我创建了 MSK 集群，并从我的 Producer 发送了一条消息。 效果很好。 而且，我想让我的消费者得到这个消息。 Consumer在一个python文件中，而python文…
