[GitHub] [kafka] lianetm commented on pull request #14346: KAFKA-15115 - KAFKA-15163; Reset/Validate positions implementation & API integration

2023-09-13 Thread via GitHub
lianetm commented on PR #14346: URL: https://github.com/apache/kafka/pull/14346#issuecomment-1717579385 There were 6 unrelated test failures in the last build: Build / JDK 20 and Scala 2.13 / testTaskRequestWithOldStartMsGetsUpdated() – org.apache.kafka.trogdor.coordinator.Coordinator

[GitHub] [kafka] lianetm commented on pull request #14346: KAFKA-15115 - KAFKA-15163; Reset/Validate positions implementation & API integration

2023-09-12 Thread via GitHub
lianetm commented on PR #14346: URL: https://github.com/apache/kafka/pull/14346#issuecomment-1716175625 All comments addressed @junrao , thanks! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to th

[GitHub] [kafka] lianetm commented on pull request #14346: KAFKA-15115 - KAFKA-15163; Reset/Validate positions implementation & API integration

2023-09-12 Thread via GitHub
lianetm commented on PR #14346: URL: https://github.com/apache/kafka/pull/14346#issuecomment-1715682457 There were 7 unrelated test failures: Build / JDK 17 and Scala 2.13 / testCreateTokenForOtherUserFails(String).quorum=kraft – kafka.api.DelegationTokenEndToEndAuthorizationWithOwne

[GitHub] [kafka] lianetm commented on pull request #14346: KAFKA-15115 - KAFKA-15163; Reset/Validate positions implementation & API integration

2023-09-11 Thread via GitHub
lianetm commented on PR #14346: URL: https://github.com/apache/kafka/pull/14346#issuecomment-1714883627 Unit tests added for the validate positions, it was definitely missing. Also minor fix for a param that ended up wrong in the last merge with the exponential backoff change. Update

[GitHub] [kafka] lianetm commented on pull request #14346: KAFKA-15115 - KAFKA-15163; Reset/Validate positions implementation & API integration

2023-09-11 Thread via GitHub
lianetm commented on PR #14346: URL: https://github.com/apache/kafka/pull/14346#issuecomment-1714633959 Thanks for the review @junrao . All comments addressed, only pending is adding more unit tests for the validatePositions. I'm adding them and will update shortly -- This is an automate

[GitHub] [kafka] lianetm commented on pull request #14346: KAFKA-15115 - KAFKA-15163; Reset/Validate positions implementation & API integration

2023-09-08 Thread via GitHub
lianetm commented on PR #14346: URL: https://github.com/apache/kafka/pull/14346#issuecomment-1712218811 Thanks for review @junrao ! All comments addressed. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above

[GitHub] [kafka] lianetm commented on pull request #14346: KAFKA-15115 - KAFKA-15163; Reset/Validate positions implementation & API integration

2023-09-08 Thread via GitHub
lianetm commented on PR #14346: URL: https://github.com/apache/kafka/pull/14346#issuecomment-1711652623 Thanks @philipnee! I had missed the reset func when renaming, done. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and u

[GitHub] [kafka] lianetm commented on pull request #14346: KAFKA-15115 - KAFKA-15163; Reset/Validate positions implementation & API integration

2023-09-07 Thread via GitHub
lianetm commented on PR #14346: URL: https://github.com/apache/kafka/pull/14346#issuecomment-1710762508 Thanks a lot @philipnee for the review, all comments addressed. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use th

[GitHub] [kafka] lianetm commented on pull request #14346: KAFKA-15115 - KAFKA-15163; Reset/Validate positions implementation & API integration

2023-09-07 Thread via GitHub
lianetm commented on PR #14346: URL: https://github.com/apache/kafka/pull/14346#issuecomment-1710621218 Build completed with 6 unrelated test failures: Build / JDK 20 and Scala 2.13 / testOffsetTranslationBehindReplicationFlow() – org.apache.kafka.connect.mirror.integration.MirrorCon