1回答
因此，由于某些原因，我无法通过Kafka Java API正确连接MSK。我可以让生产者/消费者使用conduktor和Kafka CLI工具来使用MSK。因此，我使用如下配置通过conduktor和Kafka CLI工具进行连接。security.protocol=SASL_SSLsasl.jaas.config = softwar
浏览 124提问于2021-08-31得票数 0
回答已采纳
我在AWS上运行MSK，我希望使用AWS_MSK_IAM身份验证来使用信息。..java.lang.ClassCastException: software.amazon.msk.auth.iam.IAMClientCallbackHandler cannot be cast to', 'AWS_MSK_IAM')
浏览 4提问于2021-10-29得票数 0
1回答
(MSKCredentialProvider.java:123) at software.amazon.msk.auth.iam.internals.MSKCredentialProvider<init>(MSKCredentialProvide
浏览 6提问于2022-05-26得票数 1
回答已采纳
我们正在努力让Amazon MSK ( kafka )使用IAM身份验证&此后，使用aws kafka广告侦听器中的更改，使其可通过DNS公开访问。您是否有关于可公开访问的AWS MSK和IAM身份验证问题的任何信息？基本上，我们遵循指南中的思想，特别是模式2:使用单个共享接口端点管理所有MSK代理，但使用IAM身份验证，而不是使用IAM guide for AWS MSK。(KafkaFu
浏览 56提问于2021-10-18得票数 1
我们正试图通过与启用IAM的MSK连接。
下面的属性被添加到$KAFKA_HOME/config/connect-standalone.properties中，除了需要的常规信任之外。=AWS_MSK_IAM；sasl.client.callback.handler.class=software.amazon.msk.auth.iam.IAMClientCallbackHandler但是，与MSK的连接失败了&下面的错误消息
浏览 10提问于2022-08-24得票数 0
回答已采纳
1回答
我们正在使用Aws MSK，最近他们宣布了AWS MSK IAM AUTH(https://github.com/aws/aws-msk-iam-auth) 当我试图在我的客户机上使用它时，我得到了一个异常： org.apache.kafka.common.errors.TimeoutException: Call(callName=fetchMetadata, deadlineMs=1620677932733) timed out at 1620
浏览 88提问于2021-05-11得票数 3
背景是MSK IAM有一个节流极限。max.tasksnumber of partitionsnumber of brokersreplication factor
浏览 16提问于2022-01-23得票数 1
我想创建一个Spring，它使用IAM连接到AWS，并生成和使用我在互联网上查看过的事件，但是没有找到任何好的资源。
注意:我已经在AWS上部署了我的演示应用hello world应用程序。
浏览 7提问于2022-11-03得票数 1
sasl.mechanism=AWS_MSK_IAMsasl.client.callback.handler.class=software.amazon.msk.auth.iam.IAMClientCallbackHandler
这个jar通常的工作方式是使用sasl.jaas.config属性提供用户名和密码。但是，对于无服务
浏览 14提问于2022-10-11得票数 0
回答已采纳
1回答
我在AWS EKS POD上部署了一个spring引导应用程序，并提供了带有IAM身份验证的AWS MSK，它们都在相同的VPC下，角色已经配置，在MSK入站规则中，端口9098也被添加了。为了测试EKS和MSK之间的连接性，我确实使用了代理名称和端口9098来测试telnet，它也成功地连接到了在ek pod中运行的spring引导应用程序，它给出了以下错误：
org.springframework.kafka.KafkaExceptionsasl.jaas.conf
浏览 37提问于2022-11-11得票数 0
在Spring中，我试图用AWS_MSK_IAM作为sasl.mechanism将用户连接到Kafka，但我在配置上遇到了问题。security.protocol: SASL_SSL sasl.jaas.config: software.amazon.msk.auth.iam.IAMLoginModulerequired;
sasl.client.callback.handler
浏览 13提问于2022-01-28得票数 1
回答已采纳
2回答
论MSK
、、、
for authN.sasl.mechanism = AWS_MSK_IAM# Binds SASL client implementation.
# sasl.jaas.config = software.amazon.msk.auth.iam.IAMLoginModuleUses the specified profile name to look for credentials
浏览 8提问于2022-01-17得票数 1
回答已采纳
1回答
我将kafka-connect docker镜像(confluentinc/cp-kafka-connect-base:6.0.1)部署到ECS / fargate中，为我的ECS服务分配了一个安全组，允许传入zooper keeper和kafka引导服务器流量(纯文本和TLS)，以及一个IAM角色，允许我的ECS任务对MSK集群运行kafka操作，但连接集群在尝试从MSK集群获取代理列表时仍然超时在AWS中，<e
浏览 81提问于2021-01-10得票数 0
= aws_msk_cluster.msk.arndata "terraform_remote_state" "msk_vpc" { count = var.use_msk_peering}/msk/terraform.tfstate" }我需要的是使用这个输出作为aws_iam</em
浏览 0提问于2021-11-16得票数 0
回答已采纳
我想开发一个python脚本来创建主题在MSK使用AWS SDK boto3。我没有看到任何在Kafka.client中创建主题的方法。我可以使用kafka-python，但我想使用AWS SDK或CDK
请提个建议。
浏览 3提问于2020-07-24得票数 1
consumer_config = { "sasl.mechanism": "AWS_MSK_IAM",
"sasl.jaas.config": "software.amazon.msk.auth.iam.IAMLoginModule required;","
浏览 18提问于2022-06-02得票数 1
回答已采纳
1回答
(self, 'Role', assumed_by = iam.ServicePrincipal('ec2.amazonaws.com')) ssm_policy.attach_to_role(role)
msk_policy= [iam.Poli
浏览 15提问于2021-04-05得票数 0
1回答
就最有价值的投资而言，AWS MSK在举办端到端卡夫卡事件采购时，如何与汇合点相比较呢？部署的MonitoringEase和configuringSecurity
浏览 3提问于2021-06-12得票数 0
回答已采纳
是否有人使用JavaScript成功地建立了到Amazon MSK Kafka集群的客户端连接？没有YouTube视频或在线示例AFAIK。尝试使用普通的SASL方法在KafkaJ上不起作用，因为aws不使用用户名和密码。有什么线索吗？
浏览 8提问于2021-06-13得票数 0
我有如下所示的使用者配置import org.springframework.kafka.core.DefaultKafkaConsumerFactory;
importjava.util.Map;
@Configuration
public
浏览 8提问于2022-07-21得票数 0
回答已采纳
云服务器
ICP备案
对象存储
即时通信 IM
云直播
腾讯云开发者
