[jira] [Created] (KAFKA-13156) KafkaStatusBackingStore making incorrect assumption about order of task and connector delete events

2021-08-02 Thread Nigel Liang (Jira)
Nigel Liang created KAFKA-13156: --- Summary: KafkaStatusBackingStore making incorrect assumption about order of task and connector delete events Key: KAFKA-13156 URL: https://issues.apache.org/jira/browse/KAFKA-13156

[GitHub] [kafka] dengziming edited a comment on pull request #11157: MINOR: Replace EasyMock with Mockito in test-utils module

2021-08-02 Thread GitBox
dengziming edited a comment on pull request #11157: URL: https://github.com/apache/kafka/pull/11157#issuecomment-891452141 ping @ijuma @chia7712 @mjsax to have a look. 🤝 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [kafka] dengziming commented on pull request #11157: MINOR: Replace EasyMock with Mockito in test-utils module

2021-08-02 Thread GitBox
dengziming commented on pull request #11157: URL: https://github.com/apache/kafka/pull/11157#issuecomment-891452141 ping @ijuma @chia7712 @mjsax to have a look. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [kafka] dengziming commented on pull request #9624: KAFKA-10655: wrap and catch exception for appendAsLeader failure

2021-08-02 Thread GitBox
dengziming commented on pull request #9624: URL: https://github.com/apache/kafka/pull/9624#issuecomment-891406466 Hello @abbccdda , this may have been fixed in #10909, PTAL. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[jira] [Assigned] (KAFKA-12465) Decide whether inconsistent cluster id error are fatal

2021-08-02 Thread dengziming (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dengziming reassigned KAFKA-12465: -- Assignee: dengziming > Decide whether inconsistent cluster id error are fatal > -

[GitHub] [kafka] vashu1 edited a comment on pull request #5876: KAFKA-7509: Avoid passing most non-applicable properties to producer, consumer, and admin client

2021-08-02 Thread GitBox
vashu1 edited a comment on pull request #5876: URL: https://github.com/apache/kafka/pull/5876#issuecomment-890708377 Setting those configuration options to null solves the problem for me, works with SSL: ` kafkaEndpointBuilder.kerberosRenewWindowFactor((String) null);

[GitHub] [kafka] hachikuji opened a new pull request #11164: KAFKA-13155; Fix concurrent modification in consumer shutdown

2021-08-02 Thread GitBox
hachikuji opened a new pull request #11164: URL: https://github.com/apache/kafka/pull/11164 The `TransactionalMessageCopier` tool, which is used in simulation tests attempts to close the consumer as part of a shutdown hook. Although the access is synchronized, there is no guarantee that th

[jira] [Assigned] (KAFKA-13155) ConcurrentModificationException in TransactionalMessageCopier

2021-08-02 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-13155: --- Assignee: Jason Gustafson > ConcurrentModificationException in TransactionalMessage

[jira] [Created] (KAFKA-13155) ConcurrentModificationException in TransactionalMessageCopier

2021-08-02 Thread Jason Gustafson (Jira)
Jason Gustafson created KAFKA-13155: --- Summary: ConcurrentModificationException in TransactionalMessageCopier Key: KAFKA-13155 URL: https://issues.apache.org/jira/browse/KAFKA-13155 Project: Kafka

[jira] [Updated] (KAFKA-13155) ConcurrentModificationException in TransactionalMessageCopier

2021-08-02 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-13155: Description: Caught this exception in a system test run: {code} [2021-08-02 07:51:54,528]

[GitHub] [kafka] hachikuji merged pull request #10909: KAFKA-12158: Better return type of RaftClient.scheduleAppend

2021-08-02 Thread GitBox
hachikuji merged pull request #10909: URL: https://github.com/apache/kafka/pull/10909 -- 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-unsubsc

[GitHub] [kafka] jsancio commented on a change in pull request #11159: MINOR: Change default node id in kraft broker properties

2021-08-02 Thread GitBox
jsancio commented on a change in pull request #11159: URL: https://github.com/apache/kafka/pull/11159#discussion_r681283772 ## File path: metadata/src/main/java/org/apache/kafka/controller/ClusterControlManager.java ## @@ -239,11 +239,11 @@ public void replay(RegisterBrokerRec

[GitHub] [kafka] dielhennr commented on a change in pull request #11159: MINOR: Change default node id in kraft broker properties

2021-08-02 Thread GitBox
dielhennr commented on a change in pull request #11159: URL: https://github.com/apache/kafka/pull/11159#discussion_r681202052 ## File path: metadata/src/main/java/org/apache/kafka/controller/ClusterControlManager.java ## @@ -239,11 +239,11 @@ public void replay(RegisterBrokerR

[GitHub] [kafka] pdruley opened a new pull request #11163: MINOR: doc change for minisr to clarify replicas in Kafka Config

2021-08-02 Thread GitBox
pdruley opened a new pull request #11163: URL: https://github.com/apache/kafka/pull/11163 This is a minor doc change to MinInSyncReplicasDoc to clarify what is a replica and further help users understand the importance of this configuration in relation to their producer configuration.

[GitHub] [kafka] jsancio commented on a change in pull request #11159: MINOR: Change default node id in kraft broker properties

2021-08-02 Thread GitBox
jsancio commented on a change in pull request #11159: URL: https://github.com/apache/kafka/pull/11159#discussion_r681159222 ## File path: metadata/src/main/java/org/apache/kafka/controller/ClusterControlManager.java ## @@ -239,11 +239,11 @@ public void replay(RegisterBrokerRec

[GitHub] [kafka] cmccabe merged pull request #11162: MINOR: Update KRaft README.md and upgrade.html for 3.0

2021-08-02 Thread GitBox
cmccabe merged pull request #11162: URL: https://github.com/apache/kafka/pull/11162 -- 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] [Created] (KAFKA-13154) Misleading behaviour of OffsetSpec.latest()

2021-08-02 Thread Gabi Pi. (Jira)
Gabi Pi. created KAFKA-13154: Summary: Misleading behaviour of OffsetSpec.latest() Key: KAFKA-13154 URL: https://issues.apache.org/jira/browse/KAFKA-13154 Project: Kafka Issue Type: Bug

[jira] [Resolved] (KAFKA-13095) TransactionsTest is failing in kraft mode

2021-08-02 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-13095. - Resolution: Cannot Reproduce I am closing this since `TransactionsTest` has not yet been

[jira] [Commented] (KAFKA-5164) SetSchemaMetadata does not replace the schemas in structs correctly

2021-08-02 Thread Jorge Machado (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-5164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17391645#comment-17391645 ] Jorge Machado commented on KAFKA-5164: -- Actually not solved imho. See https://issues

[GitHub] [kafka] rondagostino opened a new pull request #11162: MINOR: KRaft 3.0 Preview doc changes

2021-08-02 Thread GitBox
rondagostino opened a new pull request #11162: URL: https://github.com/apache/kafka/pull/11162 Doc changes for the KRaft 3.0 Preview release ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI build sta

[jira] [Resolved] (KAFKA-13112) Controller's committed offset get out of sync with raft client listener context

2021-08-02 Thread Jose Armando Garcia Sancio (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jose Armando Garcia Sancio resolved KAFKA-13112. Resolution: Fixed Yes. > Controller's committed offset get out of

[GitHub] [kafka] vvcephei commented on a change in pull request #11151: MINOR: Should commit a task if the consumer position advanced as well

2021-08-02 Thread GitBox
vvcephei commented on a change in pull request #11151: URL: https://github.com/apache/kafka/pull/11151#discussion_r680997728 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java ## @@ -1158,7 +1158,38 @@ public String toString(final

[jira] [Commented] (KAFKA-7883) Add schema.namespace support to SetSchemaMetadata SMT in Kafka Connect

2021-08-02 Thread Jorge Machado (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17391583#comment-17391583 ] Jorge Machado commented on KAFKA-7883: -- I propose to have following:  new parameter

[jira] [Comment Edited] (KAFKA-7883) Add schema.namespace support to SetSchemaMetadata SMT in Kafka Connect

2021-08-02 Thread Jira
[ https://issues.apache.org/jira/browse/KAFKA-7883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17391544#comment-17391544 ] Jérémy Thulliez edited comment on KAFKA-7883 at 8/2/21, 12:07 PM: -

[jira] [Reopened] (KAFKA-7883) Add schema.namespace support to SetSchemaMetadata SMT in Kafka Connect

2021-08-02 Thread Jira
[ https://issues.apache.org/jira/browse/KAFKA-7883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jérémy Thulliez reopened KAFKA-7883: The workaround does not work on every use cases > Add schema.namespace support to SetSchemaMet

[jira] [Commented] (KAFKA-7883) Add schema.namespace support to SetSchemaMetadata SMT in Kafka Connect

2021-08-02 Thread Jorge Machado (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17391536#comment-17391536 ] Jorge Machado commented on KAFKA-7883: -- Hey, I think this should not be marked as wo

[jira] [Comment Edited] (KAFKA-7883) Add schema.namespace support to SetSchemaMetadata SMT in Kafka Connect

2021-08-02 Thread Jorge Machado (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17391536#comment-17391536 ] Jorge Machado edited comment on KAFKA-7883 at 8/2/21, 11:58 AM: ---

[GitHub] [kafka] rajinisivaram opened a new pull request #11161: MINOR: Remove node from API versions cache on NetworkClient.close(nodeId)

2021-08-02 Thread GitBox
rajinisivaram opened a new pull request #11161: URL: https://github.com/apache/kafka/pull/11161 We clear the two collections that track API version requests when server disconnects, but not for local close. The PR clears them for local close as well. ### Committer Checklist (exclude

[jira] [Comment Edited] (KAFKA-10888) Sticky partition leads to uneven product msg, resulting in abnormal delays in some partitions

2021-08-02 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17391446#comment-17391446 ] Luke Chen edited comment on KAFKA-10888 at 8/2/21, 8:47 AM:

[jira] [Commented] (KAFKA-10888) Sticky partition leads to uneven product msg, resulting in abnormal delays in some partitions

2021-08-02 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17391446#comment-17391446 ] Luke Chen commented on KAFKA-10888: --- [~hachikuji], I was thinking about your suggestio

[jira] [Commented] (KAFKA-12559) Add a top-level Streams config for bounding off-heap memory

2021-08-02 Thread Borzoo Esmailloo (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17391406#comment-17391406 ] Borzoo Esmailloo commented on KAFKA-12559: -- Hi [~msundeq], are you still workin