[jira] [Created] (KAFKA-13592) Fix flaky test ControllerIntegrationTest.testTopicIdUpgradeAfterReassigningPartitions

2022-01-12 Thread David Jacot (Jira)
David Jacot created KAFKA-13592: --- Summary: Fix flaky test ControllerIntegrationTest.testTopicIdUpgradeAfterReassigningPartitions Key: KAFKA-13592 URL: https://issues.apache.org/jira/browse/KAFKA-13592 P

[GitHub] [kafka] dajac opened a new pull request #11670: MINOR: Update year in NOTICE

2022-01-12 Thread GitBox
dajac opened a new pull request #11670: URL: https://github.com/apache/kafka/pull/11670 ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI build status - [ ] Verify documentation (including upgrade not

[GitHub] [kafka] dajac commented on pull request #11670: MINOR: Update year in NOTICE

2022-01-12 Thread GitBox
dajac commented on pull request #11670: URL: https://github.com/apache/kafka/pull/11670#issuecomment-1010783804 Thanks @rajinisivaram! Merging it without waiting for the build to complete as the build do not verify the NOTICE file. -- This is an automated message from the Apache Git Serv

[GitHub] [kafka] dajac merged pull request #11670: MINOR: Update year in NOTICE

2022-01-12 Thread GitBox
dajac merged pull request #11670: URL: https://github.com/apache/kafka/pull/11670 -- 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...

[jira] [Commented] (KAFKA-6502) Kafka streams deserialization handler not committing offsets on error records

2022-01-12 Thread Aleksandr Sorokoumov (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17474389#comment-17474389 ] Aleksandr Sorokoumov commented on KAFKA-6502: - [~jadireddi] Are you actively

[GitHub] [kafka] twobeeb commented on pull request #11575: KAFKA-13511: Update TimestampConverter support unix epoch as millis, micros, and seconds

2022-01-12 Thread GitBox
twobeeb commented on pull request #11575: URL: https://github.com/apache/kafka/pull/11575#issuecomment-1011011375 Hi @mimaison, I haven't received any update on the [KIP-808](https://lists.apache.org/thread/t51lmxjdt3k4y990s2c378529lwtt0q0) which I created as per your suggestion.

[GitHub] [kafka] mimaison commented on pull request #11575: KAFKA-13511: Update TimestampConverter support unix epoch as millis, micros, and seconds

2022-01-12 Thread GitBox
mimaison commented on pull request #11575: URL: https://github.com/apache/kafka/pull/11575#issuecomment-1011045546 Sorry @twobeeb, I'll try to take a look this afternoon. Thanks -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[jira] [Commented] (KAFKA-13217) Reconsider skipping the LeaveGroup on close() or add an overload that does so

2022-01-12 Thread Seungchan Ahn (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17474548#comment-17474548 ] Seungchan Ahn commented on KAFKA-13217: --- Hi [~ableegoldman] [~guozhang] 👋 I just

[jira] [Comment Edited] (KAFKA-13217) Reconsider skipping the LeaveGroup on close() or add an overload that does so

2022-01-12 Thread Seungchan Ahn (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17474548#comment-17474548 ] Seungchan Ahn edited comment on KAFKA-13217 at 1/12/22, 2:02 PM: -

[jira] [Comment Edited] (KAFKA-13217) Reconsider skipping the LeaveGroup on close() or add an overload that does so

2022-01-12 Thread Seungchan Ahn (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17474548#comment-17474548 ] Seungchan Ahn edited comment on KAFKA-13217 at 1/12/22, 2:04 PM: -

[GitHub] [kafka] dajac opened a new pull request #11671: KAFKA-13388; Kafka Producer nodes stuck in CHECKING_API_VERSIONS

2022-01-12 Thread GitBox
dajac opened a new pull request #11671: URL: https://github.com/apache/kafka/pull/11671 At the moment, the `NetworkClient` will remain stuck in the `CHECKING_API_VERSIONS` state forever if the `Channel` does not become ready. To prevent this from happening, this patch changes the logic to

[GitHub] [kafka] dajac commented on a change in pull request #11571: KAFKA-13496: add reason to LeaveGroupRequest

2022-01-12 Thread GitBox
dajac commented on a change in pull request #11571: URL: https://github.com/apache/kafka/pull/11571#discussion_r783185731 ## File path: clients/src/test/java/org/apache/kafka/clients/admin/KafkaAdminClientTest.java ## @@ -3907,6 +3910,79 @@ public void testRemoveMembersFromGro

[GitHub] [kafka] jeffkbkim commented on a change in pull request #11571: KAFKA-13496: add reason to LeaveGroupRequest

2022-01-12 Thread GitBox
jeffkbkim commented on a change in pull request #11571: URL: https://github.com/apache/kafka/pull/11571#discussion_r783200432 ## File path: clients/src/test/java/org/apache/kafka/clients/admin/KafkaAdminClientTest.java ## @@ -3907,6 +3910,79 @@ public void testRemoveMembersFro

[GitHub] [kafka] gabrieljones commented on pull request #7898: KAFKA-9366: Change log4j dependency into log4j2

2022-01-12 Thread GitBox
gabrieljones commented on pull request #7898: URL: https://github.com/apache/kafka/pull/7898#issuecomment-1011241406 confluent also has a fork of log4j 1 https://mvnrepository.com/artifact/io.confluent/confluent-log4j/1.2.17-cp6 The github repo seems to have disappeared though. -

[GitHub] [kafka] mimaison opened a new pull request #11672: KAFKA-13577: Replace easymock with mockito in kafka:core - part 1

2022-01-12 Thread GitBox
mimaison opened a new pull request #11672: URL: https://github.com/apache/kafka/pull/11672 I've fully replaced easymock with mockito in core. As it's a pretty large change, I'm splitting it in a few PRs (2 or 3) so reviewing it is not a complete nightmare. ### Committer Checklist (e

[GitHub] [kafka] mimaison opened a new pull request #11673: KAFKA-13577: Replace easymock with mockito in kafka:core - part 2

2022-01-12 Thread GitBox
mimaison opened a new pull request #11673: URL: https://github.com/apache/kafka/pull/11673 Follow up from https://github.com/apache/kafka/pull/11672 ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI b

[GitHub] [kafka] mimaison opened a new pull request #11674: KAFKA-13577: Replace easymock with mockito in kafka:core - part 3

2022-01-12 Thread GitBox
mimaison opened a new pull request #11674: URL: https://github.com/apache/kafka/pull/11674 Follow up from https://github.com/apache/kafka/pull/11672 and https://github.com/apache/kafka/pull/11673 ### Committer Checklist (excluded from commit message) - [ ] Verify design and implem

[GitHub] [kafka] lmr3796 commented on pull request #11669: MINOR: Replace if/else with match in KafkaZkClient#getPartitionAssignmentForTopics

2022-01-12 Thread GitBox
lmr3796 commented on pull request #11669: URL: https://github.com/apache/kafka/pull/11669#issuecomment-1011328979 Hey thanks for the review @ijuma . Since I don't have the write access, I'm wondering what would be the process of merging the patch. -- This is an automated message from

[jira] [Assigned] (KAFKA-10173) BufferUnderflowException during Kafka Streams Upgrade

2022-01-12 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-10173: --- Assignee: Matthias J. Sax (was: John Roesler) > BufferUnderflowException during Ka

[jira] [Assigned] (KAFKA-10173) BufferUnderflowException during Kafka Streams Upgrade

2022-01-12 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-10173: --- Assignee: John Roesler (was: Matthias J. Sax) > BufferUnderflowException during Ka

[jira] [Commented] (KAFKA-13574) NotLeaderOrFollowerException thrown for a successful send

2022-01-12 Thread Kyle Kingsbury (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17474900#comment-17474900 ] Kyle Kingsbury commented on KAFKA-13574: Another case like this–I'm seeing trans

[jira] [Commented] (KAFKA-13289) Bulk processing correctly ordered input data through a join with kafka-streams results in `Skipping record for expired segment`

2022-01-12 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17474910#comment-17474910 ] Matthias J. Sax commented on KAFKA-13289: - {quote}However it seems the dropping

[GitHub] [kafka] wcarlson5 opened a new pull request #11675: KAFKA-12648: POC for committing tasks on error

2022-01-12 Thread GitBox
wcarlson5 opened a new pull request #11675: URL: https://github.com/apache/kafka/pull/11675 If a task has an exception while processing the it commits any tasks that were successfully processed before entering the error handling logic. ### Committer Checklist (excluded from commit me

[jira] [Created] (KAFKA-13593) ThrottledChannelReaper slows broker shutdown by multiple seconds

2022-01-12 Thread Steven Schlansker (Jira)
Steven Schlansker created KAFKA-13593: - Summary: ThrottledChannelReaper slows broker shutdown by multiple seconds Key: KAFKA-13593 URL: https://issues.apache.org/jira/browse/KAFKA-13593 Project: K

[GitHub] [kafka] hachikuji commented on a change in pull request #11666: KAFKA-13591; Fix flaky test `ControllerIntegrationTest.testTopicIdCreatedOnUpgrade`

2022-01-12 Thread GitBox
hachikuji commented on a change in pull request #11666: URL: https://github.com/apache/kafka/pull/11666#discussion_r783575296 ## File path: core/src/test/scala/unit/kafka/controller/ControllerIntegrationTest.scala ## @@ -1127,27 +1127,29 @@ class ControllerIntegrationTest exte

[jira] [Updated] (KAFKA-13549) Add "delete interval" config

2022-01-12 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13549: Description: KIP-811: [https://cwiki.apache.org/confluence/display/KAFKA/KIP-811%3A+Add+c