diff --git a/InsertRecordTimestampHeaders.md b/InsertRecordTimestampHeaders.md index cfa995d..eaea4b4 100644 --- a/InsertRecordTimestampHeaders.md +++ b/InsertRecordTimestampHeaders.md @@ -57,14 +57,14 @@ To store the epoch value, use the following configuration: ```properties transforms=InsertWallclock -transforms.InsertWallclock.type=io.lenses.connect.smt.header.InsertWallclockHeaders +transforms.InsertWallclock.type=io.lenses.connect.smt.header.InsertRecordTimestampHeaders ``` To prefix the headers with `wallclock_`, use the following: ```properties transforms=InsertWallclock -transforms.InsertWallclock.type=io.lenses.connect.smt.header.InsertWallclockHeaders +transforms.InsertWallclock.type=io.lenses.connect.smt.header.InsertRecordTimestampHeaders transforms.InsertWallclock.header.prefix.name=wallclock_ ``` @@ -72,7 +72,7 @@ To change the date format, use the following: ```properties transforms=InsertWallclock -transforms.InsertWallclock.type=io.lenses.connect.smt.header.InsertWallclockHeaders +transforms.InsertWallclock.type=io.lenses.connect.smt.header.InsertRecordTimestampHeaders transforms.InsertWallclock.date.format=yyyy-MM-dd ``` @@ -80,7 +80,7 @@ To use the timezone `Asia/Kolkoata`, use the following: ```properties transforms=InsertWallclock -transforms.InsertWallclock.type=io.lenses.connect.smt.header.InsertWallclockHeaders +transforms.InsertWallclock.type=io.lenses.connect.smt.header.InsertRecordTimestampHeaders transforms.InsertWallclock.timezone=Asia/Kolkata ``` @@ -89,7 +89,7 @@ as `date=yyyy-MM-dd / hour=HH`, employ the following SMT configuration for a par ```properties transforms=InsertWallclock -transforms.InsertWallclock.type=io.lenses.connect.smt.header.InsertWallclockHeaders +transforms.InsertWallclock.type=io.lenses.connect.smt.header.InsertRecordTimestampHeaders transforms.InsertWallclock.date.format="date=yyyy-MM-dd" transforms.InsertWallclock.hour.format="hour=yyyy" ``` @@ -98,4 +98,4 @@ and in the KCQL setting utilise the headers as partitioning keys: ```properties connect.s3.kcql=INSERT INTO $bucket:prefix SELECT * FROM kafka_topic PARTITIONBY _header.date, _header.year -``` \ No newline at end of file +```