[GitHub] [kafka] ijuma commented on pull request #12285: KAFKA-14001: Migrate streams module to JUnit 5 - Part 1

2022-07-22 Thread GitBox
ijuma commented on PR #12285: URL: https://github.com/apache/kafka/pull/12285#issuecomment-1193073368 For other modules, we did the JUnit 5 migration in one PR to avoid this problem. As @divijvaidya mentioned, the build expects each module to be JUnit 4 or JUnit 5. -- This is an automate

[GitHub] [kafka] C0urante opened a new pull request, #12433: KAFKA-14093: Use single-worker Connect cluster when testing fenced leader recovery

2022-07-22 Thread GitBox
C0urante opened a new pull request, #12433: URL: https://github.com/apache/kafka/pull/12433 Largely copied from [Jira](https://issues.apache.org/jira/browse/KAFKA-14093): The Javadoc for the `testFencedLeaderRecovery` test case calls out that it uses a one-node cluster, and the [chec

[jira] [Comment Edited] (KAFKA-14093) Flaky ExactlyOnceSourceIntegrationTest.testFencedLeaderRecovery

2022-07-22 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17570169#comment-17570169 ] Chris Egerton edited comment on KAFKA-14093 at 7/22/22 8:24 PM: --

[jira] [Commented] (KAFKA-14093) Flaky ExactlyOnceSourceIntegrationTest.testFencedLeaderRecovery

2022-07-22 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17570169#comment-17570169 ] Chris Egerton commented on KAFKA-14093: --- Think the root cause of this is rather si

[jira] [Created] (KAFKA-14098) Internal Kafka clients used by Kafka Connect should have distinguishable client IDs

2022-07-22 Thread Chris Egerton (Jira)
Chris Egerton created KAFKA-14098: - Summary: Internal Kafka clients used by Kafka Connect should have distinguishable client IDs Key: KAFKA-14098 URL: https://issues.apache.org/jira/browse/KAFKA-14098

[jira] [Updated] (KAFKA-14098) Internal Kafka clients used by Kafka Connect should have distinguishable client IDs

2022-07-22 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-14098: -- Priority: Minor (was: Major) > Internal Kafka clients used by Kafka Connect should have disti

[GitHub] [kafka] mimaison opened a new pull request, #12432: KAFKA-14095: Improve handling of sync offset failures in MirrorMaker

2022-07-22 Thread GitBox
mimaison opened a new pull request, #12432: URL: https://github.com/apache/kafka/pull/12432 We should not treat UNKNOWN_MEMBER_ID and FENCED_INSTANCE_ID as unexpected errors in the Admin client. In MirrorMaker, check the result of committing offsets and log an useful error message in case t

[jira] [Commented] (KAFKA-13868) Website updates to satisfy Apache privacy policies

2022-07-22 Thread Mickael Maison (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17570138#comment-17570138 ] Mickael Maison commented on KAFKA-13868: I think we've addressed all issues apar

[jira] [Commented] (KAFKA-13868) Website updates to satisfy Apache privacy policies

2022-07-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17570136#comment-17570136 ] ASF GitHub Bot commented on KAFKA-13868: mimaison merged PR #420: URL: https://g

[GitHub] [kafka] jonathan-albrecht-ibm commented on pull request #12343: MINOR: Update unit/integration tests to work with the IBM Semeru JDK

2022-07-22 Thread GitBox
jonathan-albrecht-ibm commented on PR #12343: URL: https://github.com/apache/kafka/pull/12343#issuecomment-1192747607 Hi @Kvicii, I have rebased this PR to trigger the tests. It looks like everything that ran passed except for 2 instances of ``` Build / JDK 8 and Scala 2.12 / testFence

[GitHub] [kafka] dstelljes commented on pull request #12295: KAFKA-13586: Prevent exception thrown during connector update from crashing distributed herder

2022-07-22 Thread GitBox
dstelljes commented on PR #12295: URL: https://github.com/apache/kafka/pull/12295#issuecomment-1192603682 @rhauch I see you merged a couple Connect pulls lately; can I bug you for this one as well? -- This is an automated message from the Apache Git Service. To respond to the message, ple

[GitHub] [kafka] mdedetrich commented on a diff in pull request #11478: KAFKA-13299: Accept duplicate listener on port for IPv4/IPv6

2022-07-22 Thread GitBox
mdedetrich commented on code in PR #11478: URL: https://github.com/apache/kafka/pull/11478#discussion_r927594387 ## core/src/main/scala/kafka/utils/CoreUtils.scala: ## @@ -252,16 +255,63 @@ object CoreUtils { listenerListToEndPoints(listeners, securityProtocolMap, true)

[GitHub] [kafka] akatona84 commented on a diff in pull request #11565: KAFKA-13504: Retry connect internal topics' creation in case of InvalidReplicationFactorException

2022-07-22 Thread GitBox
akatona84 commented on code in PR #11565: URL: https://github.com/apache/kafka/pull/11565#discussion_r927554756 ## connect/runtime/src/main/java/org/apache/kafka/connect/util/TopicAdmin.java: ## @@ -329,6 +334,48 @@ public Set createTopics(NewTopic... topics) { return c

[jira] [Commented] (KAFKA-7656) ReplicaManager fetch fails on leader due to long/integer overflow

2022-07-22 Thread Nitish Jain (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17569945#comment-17569945 ] Nitish Jain commented on KAFKA-7656: Hi [~efpe]/Team, I know this is a very old issu

[GitHub] [kafka] lhunyady commented on a diff in pull request #11565: KAFKA-13504: Retry connect internal topics' creation in case of InvalidReplicationFactorException

2022-07-22 Thread GitBox
lhunyady commented on code in PR #11565: URL: https://github.com/apache/kafka/pull/11565#discussion_r927540197 ## connect/runtime/src/main/java/org/apache/kafka/connect/util/TopicAdmin.java: ## @@ -329,6 +334,48 @@ public Set createTopics(NewTopic... topics) { return cr

[GitHub] [kafka] mdedetrich commented on a diff in pull request #11478: KAFKA-13299: Accept duplicate listener on port for IPv4/IPv6

2022-07-22 Thread GitBox
mdedetrich commented on code in PR #11478: URL: https://github.com/apache/kafka/pull/11478#discussion_r927540567 ## core/src/main/scala/kafka/utils/CoreUtils.scala: ## @@ -252,16 +255,63 @@ object CoreUtils { listenerListToEndPoints(listeners, securityProtocolMap, true)

[GitHub] [kafka] mdedetrich commented on a diff in pull request #11478: KAFKA-13299: Accept duplicate listener on port for IPv4/IPv6

2022-07-22 Thread GitBox
mdedetrich commented on code in PR #11478: URL: https://github.com/apache/kafka/pull/11478#discussion_r927539871 ## core/src/main/scala/kafka/utils/CoreUtils.scala: ## @@ -252,16 +255,63 @@ object CoreUtils { listenerListToEndPoints(listeners, securityProtocolMap, true)

[GitHub] [kafka] mdedetrich commented on a diff in pull request #11478: KAFKA-13299: Accept duplicate listener on port for IPv4/IPv6

2022-07-22 Thread GitBox
mdedetrich commented on code in PR #11478: URL: https://github.com/apache/kafka/pull/11478#discussion_r927539567 ## core/src/main/scala/kafka/utils/CoreUtils.scala: ## @@ -252,16 +255,63 @@ object CoreUtils { listenerListToEndPoints(listeners, securityProtocolMap, true)

[GitHub] [kafka] mdedetrich commented on a diff in pull request #11478: KAFKA-13299: Accept duplicate listener on port for IPv4/IPv6

2022-07-22 Thread GitBox
mdedetrich commented on code in PR #11478: URL: https://github.com/apache/kafka/pull/11478#discussion_r927536939 ## core/src/main/scala/kafka/server/KafkaConfig.scala: ## @@ -741,12 +741,15 @@ object KafkaConfig { /** * Socket Server Configuration ***/ val

[GitHub] [kafka] divijvaidya commented on pull request #12285: KAFKA-14001: Migrate streams module to JUnit 5 - Part 1

2022-07-22 Thread GitBox
divijvaidya commented on PR #12285: URL: https://github.com/apache/kafka/pull/12285#issuecomment-1192428154 Hey @clolov @cadonna Yes, I have figured out why the newly converted tests to JUnit5 are not running. There are two reasons to it: 1. There is an overall block to use JUnit5 for

[jira] [Commented] (KAFKA-2427) Error writing to highwatermark file

2022-07-22 Thread Martin Pelak (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-2427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17569927#comment-17569927 ] Martin Pelak commented on KAFKA-2427: - Hi, if you are a Windows user, you can use a f

[jira] [Commented] (KAFKA-9458) Kafka crashed in windows environment

2022-07-22 Thread Martin Pelak (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17569926#comment-17569926 ] Martin Pelak commented on KAFKA-9458: - Hi, if you are a Windows user, you can use a f

[jira] [Commented] (KAFKA-8145) Broker fails with FATAL Shutdown on Windows, log or index renaming fail

2022-07-22 Thread Martin Pelak (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17569924#comment-17569924 ] Martin Pelak commented on KAFKA-8145: - Hi, if you are a Windows user, you can use a f

[jira] [Commented] (KAFKA-6200) 00000000000000000015.timeindex: The process cannot access the file because it is being used by another process.

2022-07-22 Thread Martin Pelak (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17569923#comment-17569923 ] Martin Pelak commented on KAFKA-6200: - Hi, if you are a Windows user, you can use a f

[jira] [Commented] (KAFKA-6188) Broker fails with FATAL Shutdown - log dirs have failed

2022-07-22 Thread Martin Pelak (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17569922#comment-17569922 ] Martin Pelak commented on KAFKA-6188: - Hi, if you are a Windows user, you can use a f

[jira] [Commented] (KAFKA-6059) Kafka cant delete old log files on windows

2022-07-22 Thread Martin Pelak (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17569921#comment-17569921 ] Martin Pelak commented on KAFKA-6059: - Hi, if you are a Windows user, you can use a f

[jira] [Comment Edited] (KAFKA-14088) KafkaChannel memory leak

2022-07-22 Thread Ismael Juma (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17569873#comment-17569873 ] Ismael Juma edited comment on KAFKA-14088 at 7/22/22 9:08 AM:

[GitHub] [kafka] nicolasguyomar opened a new pull request, #12431: MINOR : typo in trace log

2022-07-22 Thread GitBox
nicolasguyomar opened a new pull request, #12431: URL: https://github.com/apache/kafka/pull/12431 *More detailed description of your change, if necessary. The PR title and PR message become the squashed commit message, so use a separate comment to ping reviewers.* *Summary of

[jira] [Commented] (KAFKA-14088) KafkaChannel memory leak

2022-07-22 Thread Ismael Juma (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17569873#comment-17569873 ] Ismael Juma commented on KAFKA-14088: - 2.2.1 is very old, do yo see this behavior wi

[GitHub] [kafka] showuon commented on a diff in pull request #11478: KAFKA-13299: Accept duplicate listener on port for IPv4/IPv6

2022-07-22 Thread GitBox
showuon commented on code in PR #11478: URL: https://github.com/apache/kafka/pull/11478#discussion_r927372305 ## core/src/main/scala/kafka/utils/CoreUtils.scala: ## @@ -252,16 +255,63 @@ object CoreUtils { listenerListToEndPoints(listeners, securityProtocolMap, true) }

[GitHub] [kafka] mnegodaev commented on pull request #11442: KAFKA-7883 add schema.namespace support to SetSchemaMetadata SMT in Kafka Connect

2022-07-22 Thread GitBox
mnegodaev commented on PR #11442: URL: https://github.com/apache/kafka/pull/11442#issuecomment-1192297843 @rhauch @mimaison @kkonstantine @pjmagee FYI I've [started](https://lists.apache.org/thread/3hkd9lljobf9rl56ogjpcbo4ldoxcz5n) a [DISCUSS] thread on the Apache mailing list for [KIP-855

[GitHub] [kafka] etolbakov opened a new pull request, #12430: KAFKA-14020: change method visibility

2022-07-22 Thread GitBox
etolbakov opened a new pull request, #12430: URL: https://github.com/apache/kafka/pull/12430 Hello, @artemlivshits As discussed in https://github.com/apache/kafka/pull/12365 the minor enhancement related to changing method visibility. -- Regards, Eugene -- This is an au

[GitHub] [kafka] urbandan commented on a diff in pull request #11565: KAFKA-13504: Retry connect internal topics' creation in case of InvalidReplicationFactorException

2022-07-22 Thread GitBox
urbandan commented on code in PR #11565: URL: https://github.com/apache/kafka/pull/11565#discussion_r927368455 ## connect/runtime/src/main/java/org/apache/kafka/connect/util/TopicAdmin.java: ## @@ -329,6 +334,48 @@ public Set createTopics(NewTopic... topics) { return cr