Questions tagged with Amazon Managed Streaming for Apache Kafka (Amazon MSK)
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.
`io.confluent.connect.storage.partitioner.DefaultPartitioner`
What would be the effect of choosing a different partitioner in s3 sink connector than default. What would be the recommended parameter...
1
answers
0
votes
596
views
asked a year agolg...
Error: kafka.common.AdminCommandFailedException: The reassignment failed due to an unexpected error.lg...
We often balance our partitions across brokers when there is an imbalance. We occasionally encounter "NO_REASSIGNMENT_IN_PROGRESS" errors in addition to reassignment directly failing at the beginning....
1
answers
0
votes
312
views
asked a year agolg...
Hi, I would like to know how to delete worker configurations of MSK from the UI or CLI cause I haven't found a way to do it.
Accepted AnswerAmazon Managed Streaming for Apache Kafka (Amazon MSK)
2
answers
0
votes
1130
views
asked a year agolg...
Hello all,
Is it possible to add tags to kafka connect connectors in AWS MSK, I cannot see tags properties in CreateConnectorCommandInput.
If yes, how to do it through aws js sdk v3.
If we cannot add...
1
answers
0
votes
409
views
asked a year agolg...
Is there a list of supported data types for MSK connectors? It doesn't seem to be anywhere mentioned in the docs. I am getting an error related to data format in kafka connector -
```
1. Converting...
1
answers
0
votes
385
views
asked a year agolg...
Getting this error when deploying a Kafka connector
```
Converting byte[] to Kafka Connect data failed due to serialization error of topic
```
Any ideas what could be causing this and how to resolve...
1
answers
0
votes
2728
views
asked a year agolg...
From CloudWatch logs:
```
[Worker-08b99ad5f119f02cd] org.apache.kafka.common.errors.TimeoutException: Call(callName=fetchMetadata, deadlineMs=1683595748944, tries=1, nextAllowedTryMs=1683595749045)...
1
answers
0
votes
612
views
asked a year agolg...
I followed [this](https://docs.aws.amazon.com/msk/latest/developerguide/serverless-getting-started.html) tutorial to provision a serverless MSK cluster.
I am not able to connect to the cluster....
1
answers
0
votes
434
views
asked a year agolg...
Hello,
I wonder if I can connect my lambda function which is in my account in a private subnet with a kafka service deployed in a public subnet in another AWS account. The idea is to connect to...
1
answers
0
votes
669
views
asked a year agolg...
I cannot connect to postgresql database and kafka cluster. I get an error even though I use the connection parameters that appear on the dashboard.
![postgresql database connection...
2
answers
1
votes
402
views
asked a year agolg...
I would like to use Kafka in KRaft mode instead of Zookeeper on AWS, since [Kraft mode seems to be the future of...
2
answers
0
votes
1412
views
asked a year agolg...
I have a MSK cluster that has an encryption at rest key that has been deleted. The cluster is still operating, but I cannot make changes to the cluster (to add SASL/SCRAM auth) due to the missing...
1
answers
0
votes
593
views
asked a year agolg...