[GitHub] [kafka] ableegoldman commented on pull request #10788: KAFKA-12648: Pt. 3 - addNamedTopology API

ableegoldman commented on pull request #10788: URL: https://github.com/apache/kafka/pull/10788#issuecomment-894057232 Just one unrelated test failure (reopened [KAFKA-13128](https://issues.apache.org/jira/browse/KAFKA-13128)): `StoreQueryIntegrationTest.shouldQueryStoresAfterAddingAndRemov

[GitHub] [kafka] ableegoldman merged pull request #10788: KAFKA-12648: Pt. 3 - addNamedTopology API

ableegoldman merged pull request #10788: URL: https://github.com/apache/kafka/pull/10788 -- 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-unsu

[GitHub] [kafka] ableegoldman commented on pull request #10788: KAFKA-12648: Pt. 3 - addNamedTopology API

ableegoldman commented on pull request #10788: URL: https://github.com/apache/kafka/pull/10788#issuecomment-894058572 Merged to trunk -- thanks all for keeping up with the reviews so far 😄 -- This is an automated message from the Apache Git Service. To respond to the message, please log

[jira] [Commented] (KAFKA-13163) Issue with MySql worker sink connector

[ https://issues.apache.org/jira/browse/KAFKA-13163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17394622#comment-17394622 ] Jordan Moore commented on KAFKA-13163: -- As the error suggests, your incoming messag

[jira] [Created] (KAFKA-13175) The state for creating a topic is marked deep, but indicates that the topic already exists.

yangshengwei created KAFKA-13175: Summary: The state for creating a topic is marked deep, but indicates that the topic already exists. Key: KAFKA-13175 URL: https://issues.apache.org/jira/browse/KAFKA-13175

[jira] [Updated] (KAFKA-13175) The state for creating a topic is is marked for deletion, but indicates that the topic already exists.

[ https://issues.apache.org/jira/browse/KAFKA-13175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yangshengwei updated KAFKA-13175: - Summary: The state for creating a topic is is marked for deletion, but indicates that the topic

[jira] [Updated] (KAFKA-13175) The state for creating a topic is is marked for deletion, but indicates that the topic already exists.

[ https://issues.apache.org/jira/browse/KAFKA-13175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yangshengwei updated KAFKA-13175: - Description: After a topic is deleted, it is created again. A message is displayed indicating th

[jira] [Updated] (KAFKA-13175) The state for creating a topic is marked for deletion, but indicates that the topic already exists.

[ https://issues.apache.org/jira/browse/KAFKA-13175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yangshengwei updated KAFKA-13175: - Summary: The state for creating a topic is marked for deletion, but indicates that the topic alr

[jira] [Updated] (KAFKA-13175) The state for creating a topic is marked for deletion, but indicates that the topic already exists.

[ https://issues.apache.org/jira/browse/KAFKA-13175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yangshengwei updated KAFKA-13175: - Description: After a topic is deleted, it is created again. A message is displayed indicating th

[jira] [Updated] (KAFKA-13175) The state for creating a topic is marked for deletion, but indicates that the topic already exists.

[ https://issues.apache.org/jira/browse/KAFKA-13175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yangshengwei updated KAFKA-13175: - Description: After a topic is deleted, it is created again. A message is displayed indicating th

[GitHub] [kafka] yangdaixai opened a new pull request #11185: KAFKA-13175; Better indicates for created topic is marked for deleti…

yangdaixai opened a new pull request #11185: URL: https://github.com/apache/kafka/pull/11185 …on. kafka.zk.AdminZkClient (#129) This patch optimization prompts when a created topic is marked for deletion. " Topic is marked for deletion." *More detailed description of your cha

[GitHub] [kafka] hjwalt commented on pull request #10566: KAFKA-12694 Avoid schema mismatch DataException when validating default values

hjwalt commented on pull request #10566: URL: https://github.com/apache/kafka/pull/10566#issuecomment-894255662 I encountered this same problem with debezium postgresql connector, where when the connector is set up with precise decimal handling, will use a struct for its numeric value. Whe

[GitHub] [kafka] mimaison commented on a change in pull request #10807: KAFKA-12797: Log the evictor of fetch sessions

mimaison commented on a change in pull request #10807: URL: https://github.com/apache/kafka/pull/10807#discussion_r684229444 ## File path: core/src/test/scala/unit/kafka/server/KafkaApisTest.scala ## @@ -2262,11 +2262,12 @@ class KafkaApisTest { Optional.empty())).asJava

[jira] [Commented] (KAFKA-9895) Truncation request on broker start up may cause OffsetOutOfRangeException

[ https://issues.apache.org/jira/browse/KAFKA-9895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17394841#comment-17394841 ] Grigory commented on KAFKA-9895: Any news on this issue ? Was this fixed in recent update

[GitHub] [kafka] wycccccc commented on a change in pull request #11137: KAFKA-13133 Replace EasyMock and PowerMock with Mockito for AbstractHerderTest

wycc commented on a change in pull request #11137: URL: https://github.com/apache/kafka/pull/11137#discussion_r684399330 ## File path: connect/runtime/src/test/java/org/apache/kafka/connect/runtime/AbstractHerderTest.java ## @@ -135,90 +133,88 @@ private final int gen

[GitHub] [kafka] dielhennr commented on a change in pull request #11179: KAFKA-13165: Validate node id, process role and quorum voters

dielhennr commented on a change in pull request #11179: URL: https://github.com/apache/kafka/pull/11179#discussion_r684429919 ## File path: core/src/main/scala/kafka/raft/RaftManager.scala ## @@ -214,6 +220,12 @@ class KafkaRaftManager[T]( KafkaRaftManager.createLogDirecto

[GitHub] [kafka] dielhennr commented on a change in pull request #11179: KAFKA-13165: Validate node id, process role and quorum voters

dielhennr commented on a change in pull request #11179: URL: https://github.com/apache/kafka/pull/11179#discussion_r684430743 ## File path: core/src/test/scala/unit/kafka/raft/RaftManagerTest.scala ## @@ -34,21 +34,30 @@ import org.mockito.Mockito._ class RaftManagerTest {

[GitHub] [kafka] hachikuji opened a new pull request #11186: KAFKA-13162: Ensure ElectLeaders is forwarded to controller

hachikuji opened a new pull request #11186: URL: https://github.com/apache/kafka/pull/11186 This patch fixes several problems with the `ElectLeaders` API in KRaft: - `KafkaApis` did not properly forward this request type to the controller. - `ControllerApis` did not handle the requ

[GitHub] [kafka] ijuma commented on pull request #11180: MINOR: Fix testResolveDnsLookupResolveCanonicalBootstrapServers

ijuma commented on pull request #11180: URL: https://github.com/apache/kafka/pull/11180#issuecomment-894560131 Thanks for the PR. I ran this test before pushing the cherry-pick, so not sure what happened. -- This is an automated message from the Apache Git Service. To respond to the mess

[GitHub] [kafka] ijuma merged pull request #11180: MINOR: Fix testResolveDnsLookupResolveCanonicalBootstrapServers

ijuma merged pull request #11180: URL: https://github.com/apache/kafka/pull/11180 -- 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...