标记有以下标签的问题: 适用于 Apache Kafka 的亚马逊托管流媒体(亚马逊 MSK)

Amazon MSK makes it easy to ingest and process streaming data in real time with fully managed Apache Kafka.

内容语言: 中文 (简体)

选择要筛选的标签
排序方式 最新

浏览下面列出的问题和回答,或者筛选和排序以缩小结果范围。

25 条结果
【以下的问题经过翻译处理】 我想从Azure EventHub迁移到AWS上的MSK。 我们使用Azure EventHub连接TinyBird并发送事件。 在这里使用MSK Connect是不是一个好选择?它是否与TinyBird有集成?
1
回答
0
点赞数
70
检视次数
profile picture
专家
已提问 1 年前
【以下的问题经过翻译处理】 我正通过AWS控制台创建一个**MSK**集群,并想使用**Kafka的OPA插件**。 OPA插件是一个[ZIP文件](https://github.com/StyraInc/opa-kafka-plugin/releases),我必须将其放置在Kafka安装的libs目录中。但是,**我该如何将这个ZIP文件上传到我的MSK集群?** 是否有一种方法连接到我的br...
1
回答
0
点赞数
44
检视次数
profile picture
专家
已提问 1 年前
【以下的问题经过翻译处理】 你好! 我已经通过CLI(<https://docs.aws.amazon.com/cli/latest/reference/kafka/create-configuration.html>)成功创建了一个集群配置,并创建了一个使用该配置的集群。 我该如何更新配置(“创建新版本”?),这将对集群产生什么影响? 我认为我不需要经常更新配置,主要是希望能够对运营...
1
回答
0
点赞数
44
检视次数
profile picture
专家
已提问 1 年前
【以下的问题经过翻译处理】 我需要自定义我的Kafka集群设置。我正在使用AWS MSK。该如何连接到我的 Broker 的文件系统?
1
回答
0
点赞数
43
检视次数
profile picture
专家
已提问 1 年前
【以下的问题经过翻译处理】 目前支持的版本(<https://docs.aws.amazon.com/msk/latest/developerguide/supported-kafka-versions.html>)存在严重问题(<https://issues.apache.org/jira/browse/KAFKA-13636>)。虽然这个问题已经在2.8.2中得到解决,但Kafka团队目前没有...
1
回答
0
点赞数
66
检视次数
profile picture
专家
已提问 1 年前
【以下的问题经过翻译处理】 在MSK中,是否可以自定义broker属性,例如`authorizer.class.name`,以启用内置的kafka.security.auth.SimpleAclAuthorizer?并且,添加一个使用SASL\_PLAINTEXT协议的监听器?如果可以,那么要在哪里设置?
1
回答
0
点赞数
27
检视次数
profile picture
专家
已提问 1 年前
【以下的问题经过翻译处理】 你好,我想知道如何使用自定义域名来作为 MSK的访问端点?我正在寻找一种解决方案,不会引起SSL问题。谢谢!
1
回答
0
点赞数
80
检视次数
profile picture
专家
已提问 1 年前
【以下的问题经过翻译处理】 我想知道能否自定义对集群进行安全补丁程序升级(和类似的维护操作)的时间计划?由于这似乎是每月在同一时间重复的事件,如果我们能将其移动到我们的集群不处在高峰期运行的时间,那就太好了(由于它是每月重复的,我认为运行的确切时间并不重要)。
1
回答
0
点赞数
80
检视次数
profile picture
专家
已提问 1 年前
【以下的问题经过翻译处理】 使用 KafkaJS 连接到 MSK 集群时收到错误代码 UNSUPPORTED_SASL_MECHANISM,虽然集群支持 IAM 和 SASL/SCRAM 身份验证。 使用的代码及错误信息如下: ``` import {AclOperationTypes, AclPermissionTypes, AclResourceTypes, Kafka, ResourceP...
1
回答
0
点赞数
49
检视次数
profile picture
专家
已提问 1 年前
【以下的问题经过翻译处理】 我们正在使用注册 Secrets Manager Secrets 进行身份验证的 MSK SCRAM。这确实需要一个单独的对称 KMS key与密钥一起使用。这些密钥需要具有“AmazonMSK_ *”的形式。我们的安全性要求通过关联的 KMS 密钥策略将对该 KMS 密钥的访问权限降至最低权限。 看起来推荐使用Condition变量。链接:<https://docs...
1
回答
0
点赞数
75
检视次数
profile picture
专家
已提问 1 年前
【以下的问题经过翻译处理】 MSK是一个很棒的服务,可以大大降低运维成本。其中一个缺失的部分是备份Kafka Topic。特别是在通过Kafka连接微服务时,这非常重要,即如果出现故障,则存在高的迁移成本. 因此,您是否有计划为MSK提供Topic备份功能,例如通过Firehose流式传输Kafka Topic到S3?
1
回答
0
点赞数
72
检视次数
profile picture
专家
已提问 1 年前
【以下的问题经过翻译处理】 我创建了一个使用IAM访问控制作为身份验证和授权机制的MSK集群。我可以在MSK控制台上看到我的集群的Broker 节点,但是当我尝试从我的kafka客户端向一个主题写入消息时,会出现“Broker may not be available”的错误。 当我使用cli命令即get-bootstrap-brokers时,“BootstrapBrokerStringSasl...
1
回答
0
点赞数
69
检视次数
profile picture
专家
已提问 1 年前