Questions tagged with Amazon Managed Streaming for Apache Kafka (Amazon MSK)
Amazon MSK makes it easy to ingest and process streaming data in real time with fully managed Apache Kafka.
Content language: English
Select up to 5 tags to filter
Sort by most recent
Browse through the questions and answers listed below or filter and sort to narrow down your results.
Hi,
Why is it not possible to configure the property **fetch.max.bytes** on MSK Brokers running Kafka version 3.6.0? The following error response is received. It should be definitely possible to...
**You can't update multiple attributes of the cluster in same request. Use a different request for each update. **This happen when i am adding PrimaryClusterConfiguration
```
Resources:
...
Hello, I need a little help with an AWS EC2 issue involving the Apache server and Nginx server on port 80.
Getting publisher id error
asked a month ago
When MSK Replicator is created it creates the topic in the destination cluster with the naming convention <sourcecluste>.<topicname>.
Q1 . If in the destination cluster if there is a topic exist with...
Hi,
Could someone please tell me the role and permission i need to assign to a postgresql database user on AWS RDS which will connect as a debezium user for cdc .
Below is the steps i have...
We have MSK Connector under account A in VPC-A that needs to connect to provisioned MSK Broker under account B in VPC-B via IAM authenticated port 9098. VPC-A and VPC-B are peered. What are all of...
Is SASL SCRAM supported for MSK Connect authentication and authorization?
Hello we noticed that during a MSK maintenance of our cluster we get producer and consumer errors. Those happen for each broker update that can span to 10 or more minutes.
For the producer part the...
Hi I've created a kafka cluster and enabled IAM authentication, I'm running an app in ECS cluster.
I have mapped a role this ECS task and this role has this policy, I can able create topic, delete...
Can you give a logic to convert my payload in record.value() to json
I'm using byte array deserializer so I'm getting my payload like...
I am replicating data from on-premises to AWS. The first component is a Mirror Maker 2.0 that passes the messages to a MSK Topic and that passes it to a MSK Connector that in turn inserts it into the...
I encountered an issue where I updated a Lambda function, which consumes messages from a Confluent Kafka topic, and deployed the new version. AWS published the new version of the Lambda. After...