Re: [PR] KAFKA-16691: [connect:transform] Support nested field paths on TimestampConverter [kafka]

2024-06-06 Thread via GitHub
C0urante commented on code in PR #15893: URL: https://github.com/apache/kafka/pull/15893#discussion_r1629805844 ## connect/transforms/src/main/java/org/apache/kafka/connect/transforms/field/SingleFieldPath.java: ## @@ -202,6 +204,225 @@ public Object valueFrom(Map map) {

Re: [PR] KAFKA-16691: [connect:transform] Support nested field paths on TimestampConverter [kafka]

2024-05-23 Thread via GitHub
jeqo commented on code in PR #15893: URL: https://github.com/apache/kafka/pull/15893#discussion_r1612459168 ## connect/transforms/src/main/java/org/apache/kafka/connect/transforms/field/SingleFieldPath.java: ## @@ -202,6 +204,225 @@ public Object valueFrom(Map map) {

Re: [PR] KAFKA-16691: [connect:transform] Support nested field paths on TimestampConverter [kafka]

2024-05-23 Thread via GitHub
jeqo commented on code in PR #15893: URL: https://github.com/apache/kafka/pull/15893#discussion_r1612458345 ## connect/transforms/src/main/java/org/apache/kafka/connect/transforms/field/SingleFieldPath.java: ## @@ -202,6 +204,225 @@ public Object valueFrom(Map map) {

Re: [PR] KAFKA-16691: [connect:transform] Support nested field paths on TimestampConverter [kafka]

2024-05-13 Thread via GitHub
C0urante commented on code in PR #15893: URL: https://github.com/apache/kafka/pull/15893#discussion_r1598401120 ## connect/transforms/src/main/java/org/apache/kafka/connect/transforms/field/SingleFieldPath.java: ## @@ -202,6 +204,225 @@ public Object valueFrom(Map map) {

Re: [PR] KAFKA-16691: [connect:transform] Support nested field paths on TimestampConverter [kafka]

2024-05-10 Thread via GitHub
jeqo commented on PR #15893: URL: https://github.com/apache/kafka/pull/15893#issuecomment-2104551065 @C0urante thanks! Agree, we should leave this change of behavior out of the scope of this PR/KIP. I have returned to the previous behavior, PTAL. -- This is an automated message from the

Re: [PR] KAFKA-16691: [connect:transform] Support nested field paths on TimestampConverter [kafka]

2024-05-09 Thread via GitHub
C0urante commented on PR #15893: URL: https://github.com/apache/kafka/pull/15893#issuecomment-2102926693 I think this leads to a change in behavior. Right now this test (surprisingly!) passes on trunk: ```java public class TimestampConverterTest { // ... @Test

[PR] KAFKA-16691: [connect:transform] Support nested field paths on TimestampConverter [kafka]

2024-05-08 Thread via GitHub
jeqo opened a new pull request, #15893: URL: https://github.com/apache/kafka/pull/15893 [KAFKA-16691] --- ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI build status - [ ] Verify