[jira] [Assigned] (KAFKA-10892) Add Topology#connectSourceStoreAndTopic as a public method

2022-01-16 Thread Daan Gerits (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daan Gerits reassigned KAFKA-10892: --- Assignee: Daan Gerits > Add Topology#connectSourceStoreAndTopic as a public method > --

[GitHub] [kafka] RivenSun2 commented on pull request #11340: KAFKA-13310 : KafkaConsumer cannot jump out of the poll method, and theā€¦

2022-01-16 Thread GitBox
RivenSun2 commented on pull request #11340: URL: https://github.com/apache/kafka/pull/11340#issuecomment-1014217819 @guozhangwang Hi, guozhang, please help to check this PR. Thanks a lot. -- This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [kafka] C0urante commented on a change in pull request #10907: KAFKA-10000: Exactly-once support for source connectors (KIP-618)

2022-01-16 Thread GitBox
C0urante commented on a change in pull request #10907: URL: https://github.com/apache/kafka/pull/10907#discussion_r785490692 ## File path: connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedConfig.java ## @@ -192,6 +198,19 @@ public stat

[jira] [Assigned] (KAFKA-13508) Introduction of "-head" flag for describe tool for broker

2022-01-16 Thread Prem Kamal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prem Kamal reassigned KAFKA-13508: -- Assignee: (was: Prem Kamal) > Introduction of "-head" flag for describe tool for broker >

[jira] [Commented] (KAFKA-13349) Allow Iterator.remove on KeyValueIterator

2022-01-16 Thread Sagar Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17476821#comment-17476821 ] Sagar Rao commented on KAFKA-13349: --- hey [~loboxu] , [~guozhang] . do you think I can

[GitHub] [kafka] vamossagar12 commented on pull request #11592: KAFKA-13501: Avoid state restore via rebalance if standbys are enabled

2022-01-16 Thread GitBox
vamossagar12 commented on pull request #11592: URL: https://github.com/apache/kafka/pull/11592#issuecomment-1013901168 hi @mjsax , could you plz review whenever you get the chance. Thanks! -- This is an automated message from the Apache Git Service. To respond to the message, please log o

[GitHub] [kafka] showuon commented on pull request #11681: KAFKA-8785: fix request timeout by waiting for brokers up at the begining

2022-01-16 Thread GitBox
showuon commented on pull request #11681: URL: https://github.com/apache/kafka/pull/11681#issuecomment-1013870941 Run twice and have no failed tests from `LeaderElectionCommandTest` ``` Build / JDK 11 and Scala 2.13 / kafka.api.PlaintextAdminIntegrationTest.testReplicaCanFetchFrom

[GitHub] [kafka] YeonCheolGit closed pull request #11663: assign only one time for size()

2022-01-16 Thread GitBox
YeonCheolGit closed pull request #11663: URL: https://github.com/apache/kafka/pull/11663 -- 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