我想用kafka connect连接mongodb和Kafka。 但我使用的是kafka MSK，没有kafka融合连接器可以使用。你知道怎么做吗？谢谢。
浏览 10提问于2020-01-14得票数 0
mongodb.hosts=test/localhost:27017mongodb.name=我想在一个远程的MSK Kafka集群上运行它。:1031) 通常，我会设法从本地机器请求Kafka MSK集群(通过使用VPN，并穿梭到EC2实例)。例如，列出远程kafka msk集群中的主题。想知道如何解
浏览 27提问于2020-01-31得票数 1
回答已采纳
我想开发一个python脚本来创建主题在MSK使用AWS SDK boto3。我没有看到任何在Kafka.client中创建主题的方法。我可以使用kafka-python，但我想使用AWS SDK或CDK
请提个建议。
浏览 3提问于2020-07-24得票数 1
1回答
我在AWS中使用Kafka MSK。因此，我们没有像在confluent上那样具有所有必需连接器的原生kafka连接。实际上，我使用kakfa mongo连接器，我想找到一种方法来将kafka mongo连接器jar推送到kafka MSK集群的实例上。
浏览 15提问于2020-01-23得票数 2
我正在尝试使用MongoDB变更流使用Kafka。我选择了AWS，因为我的整个基础设施都在AWS中，而且很容易与其他AWS服务集成。为了测试它是否与VPC有关，我将0.0.0.0白名单授予了公共访问MongoDB的权限，然后连接器就可以正常工作了。所以我相信这和VPC有关。我相信AWS MSK连接器使用与AWS MSK相同的VPC配置，因为AWS MSK连接没有单独的配置。
浏览 7提问于2021-11-05得票数 3
=4mongodb.name=mongodbmongodb.password=<admin_user_pw>database.history.kafka.bootstrap.servers=<
浏览 0提问于2021-04-24得票数 0
我认为使用lambda来使用到达AWS MSK Kafka集群中的主题的消息是微不足道的，但我无法从AWS文档中找到这样做的方法。这在某种程度上是可能的吗？
浏览 38提问于2020-08-11得票数 2
回答已采纳
我在AWS上运行MSK，我希望使用AWS_MSK_IAM身份验证来使用信息。../bin/kafka-console-consumer.sh --bootstrap-server b-1.kafka.*********.***********.amazonaws.com:9098('kafka.bootstrap.servers', 'b-.
浏览 4提问于2021-10-29得票数 0
3回答
如何在Amazon中使用Kafka适配器？根据AWS文档，它支持Kafka连接，但没有记录如何设置适配器并使用它。
浏览 4提问于2019-12-05得票数 11
回答已采纳
1回答
为了为Kafka管道启用SSL加密(仅)，我们创建了如下管道：AS LOAD DATA KAFKA '<kafka-host>:<kafka-port对于独立的Kafka集群来说，这很好。以下文档指向MSK客户端SSL加密的客户端配置。https://docs.aws.amazon.com/
浏览 0提问于2022-06-18得票数 1
回答已采纳
我需要从AWS SES获取消息并将其发布到AWS MSK (Kafka)主题。这个是可能的吗？我目前的理解是所有MSK客户端必须在同一个VPC内。我该如何正确配置Lambda函数呢？
浏览 0提问于2019-02-28得票数 3
我计划使用Amazon，我想将用户日志转储到S3。但我看不出有什么选择。我是否需要编写自己的用户，还是有一种方法可以直接将Amazon用户输出消费到s3？
浏览 4提问于2020-06-23得票数 2
回答已采纳
我们正试图通过与启用IAM的MSK连接。
下面的属性被添加到$KAFKA_HOME/config/connect-standalone.properties中，除了需要的常规信任之外。=AWS_MSK_IAM；sasl.client.callback.handler.class=software.amazon.msk.auth.iam.IAMClientCallbackHandler即使在$KAFKA_HOME/config/producer.properties中
浏览 10提问于2022-08-24得票数 0
回答已采纳
= aws_msk_cluster.msk.arndata "terraform_remote_state" "msk_vpc" { count = var.use_msk_peering1 : 0
bucket = "${var.env}-tf-state"
key = "${var.msk_peer_name}/
浏览 0提问于2021-11-16得票数 0
回答已采纳
1回答
因此，由于某些原因，我无法通过Kafka Java API正确连接MSK。我可以让生产者/消费者使用conduktor和Kafka CLI工具来使用MSK。因此，我使用如下配置通过conduktor和Kafka CLI工具进行连接。security.protocol=SASL_SSLsasl.jaas.config = software.amazon.msk.auth.iam.IAMLoginModule
浏览 124提问于2021-08-31得票数 0
回答已采纳
namespace: kafka strimzi.io/cluster: kafka-connect-cluster class: io.debezium.connector.sqlserver.SqlServerConnectorrequired username=${secrets:kafka/kafka-connect-msk-secrets:msk_sasl_user} password=${secrets:
浏览 15提问于2022-06-16得票数 1
回答已采纳
在使用aws msk connect集群创建connect应用程序时，我无法使用msk集群。但是，当创建msk连接插件时，我无法选择auth方法，该字段被禁用，如下所示。是否有人成功地使用了msk-connect-cluster ?
浏览 47提问于2021-10-01得票数 2
回答已采纳
1回答
我在AWS EKS POD上部署了一个spring引导应用程序，并提供了带有IAM身份验证的AWS MSK，它们都在相同的VPC下，角色已经配置，在MSK入站规则中，端口9098也被添加了。为了测试EKS和MSK之间的连接性，我确实使用了代理名称和端口9098来测试telnet，它也成功地连接到了在ek pod中运行的spring引导应用程序，它给出了以下错误：
org.springframework.kafka.KafkaExceptionsasl.jaas.config=software.amazon.msk<
浏览 37提问于2022-11-11得票数 0
我正在尝试为AWS MSK集群使用kafka rest代理。MSK加密详细信息：TLS加密:启用TLS加密:启用我在MSK上创建了主题"TestTopic“，然后在与MSK相同的VPC中创建了另一个作为Rest代理的以下是kafka- Here .rest.properties的详细信息：
zookeeper.connect=z-3.msk.xxxx.xx.xxxxxx-1.amazonaws.com:2181
浏览 4提问于2021-06-07得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
云直播
对象存储
腾讯会议活动推荐
腾讯云开发者
