skip to Main Content

AWS MSK Kafka connector to DynamoDB – Amazon Web Sevices

I am tyring to setup the AWS MSK connector to the DynamoDB but I cant understand how can I specify the DunamoDB key. connector.class=io.confluent.connect.aws.dynamodb.DynamoDbSinkConnector table.name.format=test_sink_table_2 confluent.topic.bootstrap.servers="someserver" tasks.max=1 topics=spk-enriched-stream aws.dynamodb.endpoint=https://dynamodb.eu-west-3.amazonaws.com confluent.topic.security.protocol=SASL_SSL confluent.topic.sasl.jaas.config=software.amazon.msk.auth.iam.IAMLoginModule required; value.converter.schemas.enable=false value.converter=org.apache.kafka.connect.converters.ByteArrayConverter key.converter=org.apache.kafka.connect.storage.StringConverter confluent.topic.sasl.client.callback.handler.class=software.amazon.msk.auth.iam.IAMClientCallbackHandler aws.dynamodb.region=eu-west-3 confluent.topic.sasl.mechanism=AWS_MSK_IAM My application…

VIEW QUESTION

Security group 'ALB-sg' is not valid – Amazon Web Sevices

I create an ALB by Cfn, but I got the error called Security group 'ALB-sg' is not valid (Service: AmazonElasticLoadBalancing; Status Code: 400; Error Code: ValidationError; Request ID: 6ec8a268-80cc-4a3e-9477-809dba8a00c7; Proxy: null) AWSTemplateFormatVersion: 2010-09-09 Description: AWS CloudFormation Sample Template for creating…

VIEW QUESTION

TypeError: command.resolveMiddleware is not a function AWS Lambda Javascript V3 – Amazon Web Sevices

I'm trying to programmatically upload a secret to an AWS Secret Manager instance using "@aws-sdk/client-secrets-manager": "^3.299.0", but I am continuously getting an error. I have followed the documentation here: https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-secrets-manager/classes/getsecretvaluecommand.html I'm using Typescript version 5.0.2 and Node 18.x as runtime,…

VIEW QUESTION
Back To Top
Search