You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
kafka-connect-s3 currently includes information about Kafka partitions and offsets when formatting the S3 object name, correct?
My use case is more timestamp-oriented and less partition/offset-oriented. Could kafka-connect-s3 generalize the S3 object naming schema, such as allowing configuration to specify a class implementing an interface like String s3ObjectName(byte[] message)? That way, users could customize the S3 name to suit their backup system needs better.
The text was updated successfully, but these errors were encountered:
kafka-connect-s3 currently includes information about Kafka partitions and offsets when formatting the S3 object name, correct?
My use case is more timestamp-oriented and less partition/offset-oriented. Could kafka-connect-s3 generalize the S3 object naming schema, such as allowing configuration to specify a class implementing an interface like
String s3ObjectName(byte[] message)
? That way, users could customize the S3 name to suit their backup system needs better.The text was updated successfully, but these errors were encountered: