Theodore Cowan

support STRUCT message keys

5

## Problem There is currently no way to sink messages with composite keys without ignoring those keys. Error "STRUCT is not supported as the document id." https://github.com/confluentinc/kafka-connect-elasticsearch/issues/193 ## Solution Convert...

Add CloudWatchOutputWriter using the v2 AWS SDK and async cloudwatch client

2

Tested on OpenJDK 1.8 - Single jar execution goal was added to include AWS SDK - Maven plugin source/target 1.8 version was required to support the single jar build -...

Could you please add a stub for lambda.invoke_with_response_stream. Thank you

[ECS] [request]: Allow Subnets and Security Groups to be defined in the Task Definition

1

### Community Note * Please vote on this issue by adding a 👍 [reaction](https://blog.github.com/2016-03-10-add-reactions-to-pull-requests-issues-and-comments/) to the original issue to help the community and maintainers prioritize this request * Please do...

KafkaSource hangs when sasl.mechaism is OAUTHBEARER with oauth_cb

2

### Bug Description KafkaSource hangs when sasl.mechaism in OAUTHBEARER with oauth_cb. It's hanging on `list_parts()` because confluent_kafka AdminClient doesn't perform the oauth callback. Cause: https://github.com/confluentinc/confluent-kafka-python/issues/1713 WORKAROUND ``` class KafkaSourceFixedForIamAuth(KafkaSource): def...