[GitHub] [kafka] fvaleri opened a new pull request, #12656: Update offset.storage.topic description

fvaleri opened a new pull request, #12656: URL: https://github.com/apache/kafka/pull/12656 This is a minor change just to clarify that this topic only stores offsets of source connector tasks. Instead, offsets for sink connector tasks are stored in __consumer_offsets, as for consumer groups

[jira] [Resolved] (KAFKA-14238) KRaft replicas can delete segments not included in a snapshot

[ https://issues.apache.org/jira/browse/KAFKA-14238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-14238. - Resolution: Fixed > KRaft replicas can delete segments not included in a snapshot >

[GitHub] [kafka] hachikuji commented on pull request #12653: KAFKA-14240; Validate kraft snapshot state on startup

hachikuji commented on PR #12653: URL: https://github.com/apache/kafka/pull/12653#issuecomment-1250074589 Test failures look unrelated. I've triggered one more build to be on the safe side. -- This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [kafka] hachikuji merged pull request #12655: KAFKA-14238; KRaft metadata log should not delete segment past the latest snapshot

hachikuji merged PR #12655: URL: https://github.com/apache/kafka/pull/12655 -- 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 the specific comment. To unsubscribe, e-mail: jira-unsubscr...@kafka.apach

[GitHub] [kafka] mdedetrich commented on pull request #12284: KAFKA-13980: Upgrade from Scala 2.12.15 to 2.12.16

mdedetrich commented on PR #12284: URL: https://github.com/apache/kafka/pull/12284#issuecomment-1250062919 Scala 2.12.17 just came out so I have rebased the PR with the new Scala version. This also means that all of the qualms mentioned in https://github.com/apache/kafka/pull/12284#issuecom

[GitHub] [kafka] agriffaut commented on pull request #12652: KAFKA-14236: ListGroups produce too much Denied logs in authorizer

agriffaut commented on PR #12652: URL: https://github.com/apache/kafka/pull/12652#issuecomment-1250047875 Also, we may use `authHelper.filterByAuthorized` instead of `groups.filter(group => authHelper.authorize( ...` -- This is an automated message from the Apache Git Service. To respond

[GitHub] [kafka] vamossagar12 commented on pull request #12561: KAFKA-12495: Exponential backoff retry to prevent rebalance storms when worker joins after revoking rebalance

vamossagar12 commented on PR #12561: URL: https://github.com/apache/kafka/pull/12561#issuecomment-1250045922 > Details I checked in the changes by fixing the 2 unit tests that were failing. This run, there didn't seem to be connect specific failures. My bad on the oversight the last

[GitHub] [kafka] agriffaut commented on pull request #12652: KAFKA-14236: ListGroups produce too much Denied logs in authorizer

agriffaut commented on PR #12652: URL: https://github.com/apache/kafka/pull/12652#issuecomment-1250030904 @hachikuji can you review that little change please ? It will save tons of unjustified logs entries -- This is an automated message from the Apache Git Service. To respond to the me