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.
I am dealing with an `OutOfMemoryError: Java heap space` from my Kafka connector running on MSK Connect. While I see several options for how to change CPU resources, I can't find a way to adjust the...
Accepted AnswerAmazon Managed Streaming for Apache Kafka (Amazon MSK)
1
answers
0
votes
467
views
asked 4 months agolg...
if i am using MSK Replicator to replicate MSK topic data and consumer offset from cluster X to cluster Y and suddenly cluster X crashes, so i recreate a new cluster and i prefer use the same name X,...
1
answers
0
votes
799
views
asked 4 months agolg...
I am trying to import an MSK Cluster into the cloudformation stack. During this process CF tries to update the resource "Apply stack-level tags to imported resource if applicable" and it fails cause...
1
answers
0
votes
433
views
asked 4 months agolg...
MSK upgrade from 2.8lg...
currently i am using MSK 2.8.2.tiered, i would like to upgrade to 3.x, but the terraform always asks to recreate the cluster, does MSK support upgrade to 3.x from 2.8.2.tiered?
1
answers
0
votes
509
views
asked 4 months agolg...
I am unable to access the public endpoint from local machine using IAM authentication via .net. Token is getting generated in the code via OAuthBearer which is IAM in this case.
Broker allows IAM...
2
answers
0
votes
549
views
asked 5 months agolg...
Connector state information
Code: InvalidInput.WorkerLogsError
```
Message: Could not enable/disable worker logs. For more information, see the Amazon MSK Connect Developer Guide. Message: User:...
1
answers
0
votes
418
views
asked 5 months agolg...
[DestinationConfig](https://docs.aws.amazon.com/lambda/latest/dg/API_CreateEventSourceMapping.html#SSS-CreateEventSourceMapping-request-DestinationConfig) is a configuration object that specifies the...
1
answers
0
votes
1269
views
asked 5 months agolg...
We have a materialized view from a MSK topic with auto refresh on. We would like to delete rows that were ingested > 78 hours (see delete operation below). The DELETE SQL is syntactically correct but...
1
answers
0
votes
652
views
asked 5 months agolg...
MSK connectors are trying to create s3 sink connectors. At this time, schema uses the schema in the Glue schema registry, and the goal is to store avro schema in s3 in parquet format.
Below is the...
0
answers
0
votes
334
views
asked 5 months agolg...
**What I'm trying to do:**
I want to run the Python file in EC2 to send data to MSK, and I want to save the data in MSK in Parquet format in S3 through the Sink connector.
**Problem:**
An error...
0
answers
0
votes
344
views
asked 5 months agolg...
I am running into an issue with my MSK cluster's broker prometheus metrics. The JMX metrics endpoint constantly returns 429 (too many requests) errors when prometheus attempts to scrape the /metrics...
1
answers
1
votes
505
views
asked 5 months agolg...
![Enter image description here](/media/postImages/original/IMsCdSahucQjqNNIkdr0VPDw)
![Enter image description here](/media/postImages/original/IM8yhsUwYIQi6-xqogiklOuw)
Hi
AWS Kafka not working...
0
answers
0
votes
334
views
asked 6 months agolg...