kafka-connect-storage-common
kafka-connect-storage-common copied to clipboard
Ability to use epoch and to also specify the format of a RecordField when using TimeBasedPartitioner
Hi. I added some functionality to use epoch seconds and to also specify the format of a RecordField when using TimeBasedPartitioner. For this I added two configuration attributes.
is.epoch can be true but defaults to false.
timestamp.field.format which expects a java date format string.
I think it is useful and would like to share it. Thanks.
-BW
@confluentinc It looks like @bwilliams42 just signed our Contributor License Agreement. :+1:
Always at your service,
clabot
@kkonstantine happy Wednesday.I'm pinging you as I'm not sure what the protocol is. So if this is incorrect i apologize and ask that you let me know what the preferred process is. Thanks.
AFAIK, this feature set is already possible by putting a TimestampConverter$Value ahead of the Sink connector
AFAIK, this feature set is already possible by putting a
TimestampConverter$Valueahead of the Sink connector
@cricket007 Thats true, but timestampConverter changes the value of the field. There may be cases where we don't want to update the field value and keep it in same format.