{"payload":{"feedbackUrl":"https://github.com/orgs/community/discussions/53140","repo":{"id":659883279,"defaultBranch":"main","name":"kafka-connect-smt","ownerLogin":"lensesio","currentUserCanPush":false,"isFork":false,"isEmpty":false,"createdAt":"2023-06-28T19:17:11.000Z","ownerAvatar":"https://avatars.githubusercontent.com/u/11728472?v=4","public":true,"private":false,"isOrgOwned":true},"refInfo":{"name":"","listCacheKey":"v0:1719418323.0","currentOid":""},"activityList":{"items":[{"before":"441b9bfc8fb6c1a5247bb459550e2a56604fb638","after":"61f1e452bd80c419152eb0860105e8a88b04bc50","ref":"refs/heads/main","pushedAt":"2024-06-21T16:08:36.000Z","pushType":"pr_merge","commitsCount":4,"pusher":{"login":"andrewstevenson","name":"Andrew Stevenson","path":"/andrewstevenson","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/10235749?s=80&v=4"},"commit":{"message":"Merge pull request #14 from davidsloan/feat/insert-source-partition-of-offset-value\n\nSMT to Insert Source Partition/Offset Metadata into Headers","shortMessageHtmlLink":"Merge pull request <a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2360632274\" data-permission-text=\"Title is private\" data-url=\"https://github.com/lensesio/kafka-connect-smt/issues/14\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/lensesio/kafka-connect-smt/pull/14/hovercard\" href=\"https://github.com/lensesio/kafka-connect-smt/pull/14\">#14</a> from davidsloan/feat/insert-source-partition-o…"}},{"before":"2bd16e86f8943e3c2106758e88418b02c4dad238","after":"441b9bfc8fb6c1a5247bb459550e2a56604fb638","ref":"refs/heads/main","pushedAt":"2024-04-08T20:59:49.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"stheppi","name":"Stefan Bocutiu","path":"/stheppi","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2507367?s=80&v=4"},"commit":{"message":"Fix the documentations for the insert record timestamp headers SMT","shortMessageHtmlLink":"Fix the documentations for the insert record timestamp headers SMT"}},{"before":"bbb4d23dfd208d563ec48db95ab9b092604b3923","after":null,"ref":"refs/heads/fix/connect-runtime-nonsense","pushedAt":"2024-04-04T21:02:27.000Z","pushType":"branch_deletion","commitsCount":0,"pusher":{"login":"stheppi","name":"Stefan Bocutiu","path":"/stheppi","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2507367?s=80&v=4"}},{"before":"3e96036db09b0ac77f5f4def7918085e18b0b887","after":"2bd16e86f8943e3c2106758e88418b02c4dad238","ref":"refs/heads/main","pushedAt":"2024-04-04T21:02:21.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"stheppi","name":"Stefan Bocutiu","path":"/stheppi","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2507367?s=80&v=4"},"commit":{"message":"Connect Runtime fails initialising the static ctor for InsertRollingFieldTimestampHeaders (#13)\n\nIt's not clear why but the code `RecordFieldTimestamp.extendConfigDef(InsertRollingTimestampHeaders.CONFIG_DEF);` gets Connect plugin scanner throwing an exception. For reasons beyond the code implementation it thinks the code redefines the setting entry named: `field`.\r\n\r\nThe solution is to redefine the ConfigDef and avoid referencing the static values defined in th parent classes.\r\n\r\nCo-authored-by: stheppi <jenkins@lenses.io>","shortMessageHtmlLink":"Connect Runtime fails initialising the static ctor for InsertRollingF…"}},{"before":null,"after":"bbb4d23dfd208d563ec48db95ab9b092604b3923","ref":"refs/heads/fix/connect-runtime-nonsense","pushedAt":"2024-04-04T21:00:38.000Z","pushType":"branch_creation","commitsCount":0,"pusher":{"login":"stheppi","name":"Stefan Bocutiu","path":"/stheppi","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2507367?s=80&v=4"},"commit":{"message":"Connect Runtime fails initialising the static ctor for InsertRollingFieldTimestampHeaders\n\nIt's not clear why but the code `RecordFieldTimestamp.extendConfigDef(InsertRollingTimestampHeaders.CONFIG_DEF);` gets Connect plugin scanner throwing an exception. For reasons beyond the code implementation it thinks the code redefines the setting entry named: `field`.\n\nThe solution is to redefine the ConfigDef and avoid referencing the static values defined in th parent classes.","shortMessageHtmlLink":"Connect Runtime fails initialising the static ctor for InsertRollingF…"}},{"before":"1569a9712a4d7da9b7a112e7c364b11b95e3b6e2","after":null,"ref":"refs/heads/fix/more_docs","pushedAt":"2024-04-03T07:53:29.000Z","pushType":"branch_deletion","commitsCount":0,"pusher":{"login":"stheppi","name":"Stefan Bocutiu","path":"/stheppi","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2507367?s=80&v=4"}},{"before":"48912435c8383b618a958981fc9f2a8deaf80bf8","after":"3e96036db09b0ac77f5f4def7918085e18b0b887","ref":"refs/heads/main","pushedAt":"2024-04-03T07:53:25.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"stheppi","name":"Stefan Bocutiu","path":"/stheppi","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2507367?s=80&v=4"},"commit":{"message":"Fix the Field Timestamp docs (#12)\n\nCo-authored-by: stheppi <jenkins@lenses.io>","shortMessageHtmlLink":"Fix the Field Timestamp docs (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2222168509\" data-permission-text=\"Title is private\" data-url=\"https://github.com/lensesio/kafka-connect-smt/issues/12\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/lensesio/kafka-connect-smt/pull/12/hovercard\" href=\"https://github.com/lensesio/kafka-connect-smt/pull/12\">#12</a>)"}},{"before":null,"after":"1569a9712a4d7da9b7a112e7c364b11b95e3b6e2","ref":"refs/heads/fix/more_docs","pushedAt":"2024-04-03T07:49:23.000Z","pushType":"branch_creation","commitsCount":0,"pusher":{"login":"stheppi","name":"Stefan Bocutiu","path":"/stheppi","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2507367?s=80&v=4"},"commit":{"message":"Fix the Field Timestamp docs","shortMessageHtmlLink":"Fix the Field Timestamp docs"}},{"before":"c8befa22bf66cbac8a69ca27b195e414d06ad275","after":null,"ref":"refs/heads/fix/docs","pushedAt":"2024-04-02T15:45:22.000Z","pushType":"branch_deletion","commitsCount":0,"pusher":{"login":"stheppi","name":"Stefan Bocutiu","path":"/stheppi","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2507367?s=80&v=4"}},{"before":"9b32f24667e8e61e26e0a78a97b175d793645db6","after":"48912435c8383b618a958981fc9f2a8deaf80bf8","ref":"refs/heads/main","pushedAt":"2024-04-02T15:44:12.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"stheppi","name":"Stefan Bocutiu","path":"/stheppi","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2507367?s=80&v=4"},"commit":{"message":"Fix the docs title (#11)\n\nCo-authored-by: stheppi <jenkins@lenses.io>","shortMessageHtmlLink":"Fix the docs title (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2220856360\" data-permission-text=\"Title is private\" data-url=\"https://github.com/lensesio/kafka-connect-smt/issues/11\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/lensesio/kafka-connect-smt/pull/11/hovercard\" href=\"https://github.com/lensesio/kafka-connect-smt/pull/11\">#11</a>)"}},{"before":null,"after":"c8befa22bf66cbac8a69ca27b195e414d06ad275","ref":"refs/heads/fix/docs","pushedAt":"2024-04-02T15:43:51.000Z","pushType":"branch_creation","commitsCount":0,"pusher":{"login":"stheppi","name":"Stefan Bocutiu","path":"/stheppi","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2507367?s=80&v=4"},"commit":{"message":"Fix the docs title","shortMessageHtmlLink":"Fix the docs title"}},{"before":"9b32f24667e8e61e26e0a78a97b175d793645db6","after":null,"ref":"refs/tags/v1.2.0","pushedAt":"2024-04-02T15:33:34.000Z","pushType":"branch_deletion","commitsCount":0,"pusher":{"login":"stheppi","name":"Stefan Bocutiu","path":"/stheppi","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2507367?s=80&v=4"}},{"before":"9a5b46a202d0f17ae7139d28ed290338013fbe77","after":"9b32f24667e8e61e26e0a78a97b175d793645db6","ref":"refs/heads/main","pushedAt":"2024-03-29T09:25:12.000Z","pushType":"pr_merge","commitsCount":3,"pusher":{"login":"andrewstevenson","name":"Andrew Stevenson","path":"/andrewstevenson","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/10235749?s=80&v=4"},"commit":{"message":"Merge pull request #9 from lensesio/feat/LC-166\n\nSupport record field timestamp","shortMessageHtmlLink":"Merge pull request <a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2213677623\" data-permission-text=\"Title is private\" data-url=\"https://github.com/lensesio/kafka-connect-smt/issues/9\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/lensesio/kafka-connect-smt/pull/9/hovercard\" href=\"https://github.com/lensesio/kafka-connect-smt/pull/9\">#9</a> from lensesio/feat/LC-166"}},{"before":"4dced00f69ae492715e8a0fc1245a836556d16ea","after":"13d66d1427e49406ba2f57105a2e05671c6074b4","ref":"refs/heads/feat/LC-166","pushedAt":"2024-03-28T21:41:44.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"stheppi","name":"Stefan Bocutiu","path":"/stheppi","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2507367?s=80&v=4"},"commit":{"message":"Adding the docs and the license headers","shortMessageHtmlLink":"Adding the docs and the license headers"}},{"before":"39bb8eb13e81d451c512be5317835637d5594e37","after":"4dced00f69ae492715e8a0fc1245a836556d16ea","ref":"refs/heads/feat/LC-166","pushedAt":"2024-03-28T21:16:39.000Z","pushType":"force_push","commitsCount":0,"pusher":{"login":"stheppi","name":"Stefan Bocutiu","path":"/stheppi","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2507367?s=80&v=4"},"commit":{"message":"Support record field timestamp\n\nThis PR introduces a new SMT which allows picking a field from the payload and use it as source for introducing the headers for time-based object key values in Lenses datalakes connectors","shortMessageHtmlLink":"Support record field timestamp"}},{"before":"dae8cb3d1d77298dbd30eb9aca6e6bd80375427d","after":null,"ref":"refs/heads/fix/public_class","pushedAt":"2024-03-28T21:10:09.000Z","pushType":"branch_deletion","commitsCount":0,"pusher":{"login":"stheppi","name":"Stefan Bocutiu","path":"/stheppi","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2507367?s=80&v=4"}},{"before":"795306a1ff601627def931da6a097c1cb1758217","after":"9a5b46a202d0f17ae7139d28ed290338013fbe77","ref":"refs/heads/main","pushedAt":"2024-03-28T21:10:06.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"stheppi","name":"Stefan Bocutiu","path":"/stheppi","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2507367?s=80&v=4"},"commit":{"message":"Fix public visibility of rolling timestamp headers (#10)\n\nCo-authored-by: stheppi <jenkins@lenses.io>","shortMessageHtmlLink":"Fix public visibility of rolling timestamp headers (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2214157487\" data-permission-text=\"Title is private\" data-url=\"https://github.com/lensesio/kafka-connect-smt/issues/10\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/lensesio/kafka-connect-smt/pull/10/hovercard\" href=\"https://github.com/lensesio/kafka-connect-smt/pull/10\">#10</a>)"}},{"before":null,"after":"dae8cb3d1d77298dbd30eb9aca6e6bd80375427d","ref":"refs/heads/fix/public_class","pushedAt":"2024-03-28T21:09:11.000Z","pushType":"branch_creation","commitsCount":0,"pusher":{"login":"stheppi","name":"Stefan Bocutiu","path":"/stheppi","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2507367?s=80&v=4"},"commit":{"message":"Fix public visibility of rolling timestamp headers","shortMessageHtmlLink":"Fix public visibility of rolling timestamp headers"}},{"before":null,"after":"39bb8eb13e81d451c512be5317835637d5594e37","ref":"refs/heads/feat/LC-166","pushedAt":"2024-03-28T16:43:34.000Z","pushType":"branch_creation","commitsCount":0,"pusher":{"login":"stheppi","name":"Stefan Bocutiu","path":"/stheppi","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2507367?s=80&v=4"},"commit":{"message":"Support record field timestamp\n\nThis PR introduces a new SMT which allows picking a field from the payload and use it as source for introducing the headers for time-based object key values in Lenses datalakes connectors","shortMessageHtmlLink":"Support record field timestamp"}},{"before":"6d923d2ff1706740b847c9318f513d425efd0d65","after":null,"ref":"refs/heads/fix/ctor_visibility","pushedAt":"2024-03-13T21:45:51.000Z","pushType":"branch_deletion","commitsCount":0,"pusher":{"login":"stheppi","name":"Stefan Bocutiu","path":"/stheppi","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2507367?s=80&v=4"}},{"before":"d16ee97d5dc82d4d20c44f9493b9d565429fa44e","after":"795306a1ff601627def931da6a097c1cb1758217","ref":"refs/heads/main","pushedAt":"2024-03-13T21:45:00.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"stheppi","name":"Stefan Bocutiu","path":"/stheppi","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2507367?s=80&v=4"},"commit":{"message":"SMTs ctors visibility (#8)\n\nSome of the SMTs introduced recently had the ctor visibility set to protected.\r\n\r\nCo-authored-by: stheppi <jenkins@lenses.io>","shortMessageHtmlLink":"SMTs ctors visibility (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2184941784\" data-permission-text=\"Title is private\" data-url=\"https://github.com/lensesio/kafka-connect-smt/issues/8\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/lensesio/kafka-connect-smt/pull/8/hovercard\" href=\"https://github.com/lensesio/kafka-connect-smt/pull/8\">#8</a>)"}},{"before":null,"after":"6d923d2ff1706740b847c9318f513d425efd0d65","ref":"refs/heads/fix/ctor_visibility","pushedAt":"2024-03-13T21:43:35.000Z","pushType":"branch_creation","commitsCount":0,"pusher":{"login":"stheppi","name":"Stefan Bocutiu","path":"/stheppi","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2507367?s=80&v=4"},"commit":{"message":"SMTs ctors visibility\n\nSome of the SMTs introduced recently had the ctor visibility set to protected.","shortMessageHtmlLink":"SMTs ctors visibility"}},{"before":"de398c5ed697b7cc0040e2b53769b6f0211bc335","after":null,"ref":"refs/heads/stheppi-patch-1","pushedAt":"2024-03-12T15:35:09.000Z","pushType":"branch_deletion","commitsCount":0,"pusher":{"login":"stheppi","name":"Stefan Bocutiu","path":"/stheppi","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2507367?s=80&v=4"}},{"before":"a34b80351b277f622e206fb1e22e0ce5171c4bc4","after":"d16ee97d5dc82d4d20c44f9493b9d565429fa44e","ref":"refs/heads/main","pushedAt":"2024-03-12T15:35:05.000Z","pushType":"pr_merge","commitsCount":2,"pusher":{"login":"stheppi","name":"Stefan Bocutiu","path":"/stheppi","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2507367?s=80&v=4"},"commit":{"message":"Merge pull request #7 from lensesio/stheppi-patch-1\n\nUpdate InsertRecordTimestampHeaders.md","shortMessageHtmlLink":"Merge pull request <a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2181950980\" data-permission-text=\"Title is private\" data-url=\"https://github.com/lensesio/kafka-connect-smt/issues/7\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/lensesio/kafka-connect-smt/pull/7/hovercard\" href=\"https://github.com/lensesio/kafka-connect-smt/pull/7\">#7</a> from lensesio/stheppi-patch-1"}},{"before":null,"after":"de398c5ed697b7cc0040e2b53769b6f0211bc335","ref":"refs/heads/stheppi-patch-1","pushedAt":"2024-03-12T15:34:19.000Z","pushType":"branch_creation","commitsCount":0,"pusher":{"login":"stheppi","name":"Stefan Bocutiu","path":"/stheppi","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2507367?s=80&v=4"},"commit":{"message":"Update InsertRecordTimestampHeaders.md\n\nFix the SMT class name","shortMessageHtmlLink":"Update InsertRecordTimestampHeaders.md"}},{"before":"c5f1678776c3870f2e0b0ce835426e4696ce17cf","after":null,"ref":"refs/heads/feat/LC-134","pushedAt":"2024-03-12T11:24:33.000Z","pushType":"branch_deletion","commitsCount":0,"pusher":{"login":"stheppi","name":"Stefan Bocutiu","path":"/stheppi","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2507367?s=80&v=4"}},{"before":"93dbeb6d04db41c27098c63ace2e48367d9e87d7","after":"a34b80351b277f622e206fb1e22e0ce5171c4bc4","ref":"refs/heads/main","pushedAt":"2024-03-12T11:24:30.000Z","pushType":"pr_merge","commitsCount":4,"pusher":{"login":"stheppi","name":"Stefan Bocutiu","path":"/stheppi","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2507367?s=80&v=4"},"commit":{"message":"Merge pull request #6 from lensesio/feat/LC-134\n\nSimplify S3/Azure/GCS Sink Configuration","shortMessageHtmlLink":"Merge pull request <a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2179538201\" data-permission-text=\"Title is private\" data-url=\"https://github.com/lensesio/kafka-connect-smt/issues/6\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/lensesio/kafka-connect-smt/pull/6/hovercard\" href=\"https://github.com/lensesio/kafka-connect-smt/pull/6\">#6</a> from lensesio/feat/LC-134"}},{"before":"f70077ada073f97feac73a8708892ce284b2e9dd","after":"c5f1678776c3870f2e0b0ce835426e4696ce17cf","ref":"refs/heads/feat/LC-134","pushedAt":"2024-03-12T11:19:04.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"stheppi","name":"Stefan Bocutiu","path":"/stheppi","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2507367?s=80&v=4"},"commit":{"message":"Fix the KCQL expamples to qualify the header fields.","shortMessageHtmlLink":"Fix the KCQL expamples to qualify the header fields."}},{"before":"a3dc6bf4588db6de99f411d4500b7c4ee9f51a46","after":"f70077ada073f97feac73a8708892ce284b2e9dd","ref":"refs/heads/feat/LC-134","pushedAt":"2024-03-11T16:17:29.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"stheppi","name":"Stefan Bocutiu","path":"/stheppi","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2507367?s=80&v=4"},"commit":{"message":"Add the file license header","shortMessageHtmlLink":"Add the file license header"}},{"before":null,"after":"a3dc6bf4588db6de99f411d4500b7c4ee9f51a46","ref":"refs/heads/feat/LC-134","pushedAt":"2024-03-11T16:14:40.000Z","pushType":"branch_creation","commitsCount":0,"pusher":{"login":"stheppi","name":"Stefan Bocutiu","path":"/stheppi","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2507367?s=80&v=4"},"commit":{"message":"Simplify S3/Azure/GCS Sink Configuration\n\nWhen dealing with partitioned data, such as using formats like `yyyy/MM/dd/HH` or `yyyy-MM-dd`/`HH`, users often face complexity in configuration. This complexity arises from needing multiple Single Message Transforms (SMTs) for each partition component, leading to a cumbersome setup. Additional settings like timezone or rolling window further compound the configuration size.\n\nThis PR addresses this complexity by introducing four new SMTs to streamline configuration:\n\n1. Wallclock headers\n2. Wallclock headers with rolling window\n3. Record timestamp headers\n4. Record timestamp headers with rolling window\n\nEach of these SMTs adds headers to the resulting record, including date, year, month, day, hour, minute, and second. Users can customize the format of each header, allowing for flexibility. For instance, to support Hive-like partition naming, users can set the `date.format` to `day=yyyy/MM/dd`.\n\nMoreover, users can optionally prefix the headers. This enhancement aims to make these headers available directly in the S3/Azure/GCS KCQL setting, simplifying the configuration process. For example:\n\n```\nconnect.s3.kcql=INSERT INTO $bucket:prefix SELECT * FROM kafka_topic PARTITIONBY date, year\n```","shortMessageHtmlLink":"Simplify S3/Azure/GCS Sink Configuration"}}],"hasNextPage":true,"hasPreviousPage":false,"activityType":"all","actor":null,"timePeriod":"all","sort":"DESC","perPage":30,"cursor":"djE6ks8AAAAEa8SRjwA","startCursor":null,"endCursor":null}},"title":"Activity · lensesio/kafka-connect-smt"}