python (65.2k questions)
javascript (44.3k questions)
reactjs (22.7k questions)
java (20.8k questions)
c# (17.4k questions)
html (16.3k questions)
r (13.7k questions)
android (13k questions)
Kafka Connect S3 Sink add MetaData
I am trying to add the metadata to the output from kafka into the S3 bucket.
Currently, the output is just the values from the messages from the kafka topic.
I want to get it wrapped with the followin...
holpender
Votes: 0
Answers: 1
Can Confluent's S3 Sink Connector for Kafka Connect write topics to a nested (not a top-level) folder in an S3 bucket using `topics.dir`?
Can Confluent's S3 Sink Connector for Kafka Connect write topics to a nested (not a top-level) folder in an S3 bucket using topics.dir?
For example, if I set topics.dir to the value thisistoplevel/thi...
benjaminedwardwebb
Votes: 0
Answers: 1
Is there a way to update connector configuration using MSK-connect API?
I have an s3 connector deployed on MSK Connect, and a repository on github with the json connector configuration file. I'd like to update the connectors configuration on demand via MSK's REST API. I'v...

omer
Votes: 0
Answers: 2
Implementing custom partitions for s3 kafka connect sink
I want to implement a custom s3 partitioner class to include some avro message fields and some extra logic to generate the output s3 path prefix
The project is in kotlin, this is my class:
package co....
alex88
Votes: 0
Answers: 1