[GitHub] [kafka] showuon opened a new pull request #11681: KAFKA-8785: fix flaky request timeout error by waiting for brokers up at the begining

showuon opened a new pull request #11681: URL: https://github.com/apache/kafka/pull/11681 ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI build status - [ ] Verify documentation (including upgra

[jira] [Assigned] (KAFKA-8541) Flakey test LeaderElectionCommandTest#testTopicPartition

[ https://issues.apache.org/jira/browse/KAFKA-8541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reassigned KAFKA-8541: Assignee: Luke Chen > Flakey test LeaderElectionCommandTest#testTopicPartition > -

[GitHub] [kafka] showuon commented on pull request #11616: MINOR: update the description in Kraft example properties file

showuon commented on pull request #11616: URL: https://github.com/apache/kafka/pull/11616#issuecomment-1013601840 @rondagostino , thanks for the comments. I've updated the PR in this commit: https://github.com/apache/kafka/pull/11616/commits/4b1363c01641a5f77d1f54b26286800818e98da9. Please

[GitHub] [kafka] showuon commented on pull request #11631: [WIP] KAFKA-13563: clear FindCoordinatorFuture for non consumer group mode

showuon commented on pull request #11631: URL: https://github.com/apache/kafka/pull/11631#issuecomment-1013598333 @guozhangwang @ableegoldman , please take a look when available. Thanks. -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[jira] [Comment Edited] (KAFKA-13588) We should consolidate `changelogFor` methods to simplify the generation of internal topic names

[ https://issues.apache.org/jira/browse/KAFKA-13588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17476360#comment-17476360 ] Saad Ur Rahman edited comment on KAFKA-13588 at 1/15/22, 12:36 AM: ---

[jira] [Commented] (KAFKA-13594) In TNPM Wireline Project, vulnerability found in Log4j-1.2.17.jar under KAFKA directory

[ https://issues.apache.org/jira/browse/KAFKA-13594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17476483#comment-17476483 ] Jun Rao commented on KAFKA-13594: - [~Waseem_bhura] : Once you remove JMSAppender, it sho

[jira] [Commented] (KAFKA-7809) Getting uncaught exception in kafka-producer-network-thread | producer-7686: java.lang.OutOfMemoryError: Java heap space

[ https://issues.apache.org/jira/browse/KAFKA-7809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17476413#comment-17476413 ] Patrick McEvoy commented on KAFKA-7809: --- I am seeing a similar issue and stack trac

[jira] [Comment Edited] (KAFKA-7809) Getting uncaught exception in kafka-producer-network-thread | producer-7686: java.lang.OutOfMemoryError: Java heap space

[ https://issues.apache.org/jira/browse/KAFKA-7809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17476413#comment-17476413 ] Patrick McEvoy edited comment on KAFKA-7809 at 1/14/22, 8:40 PM: --

[jira] [Commented] (KAFKA-13588) We should consolidate `changelogFor` methods to simplify the generation of internal topic names

[ https://issues.apache.org/jira/browse/KAFKA-13588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17476360#comment-17476360 ] Saad Ur Rahman commented on KAFKA-13588: I would like to give this a go so that

[jira] [Commented] (KAFKA-13590) Rename InternalTopologyBuilder's #topicGroups method to be more descriptive

[ https://issues.apache.org/jira/browse/KAFKA-13590?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17476271#comment-17476271 ] Kvicii.Yu commented on KAFKA-13590: --- rename is a problem.But what is more appropriate?

[GitHub] [kafka] jeffkbkim opened a new pull request #11680: MINOR: remove version check when setting reason for Join/LeaveGroupRequest

jeffkbkim opened a new pull request #11680: URL: https://github.com/apache/kafka/pull/11680 set reason field for all api versions in `JOIN_GROUP` and `LEAVE_GROUP` to test cases where newer clients speak with older brokers. ### Committer Checklist (excluded from commit message)

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

[ https://issues.apache.org/jira/browse/KAFKA-13592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17476170#comment-17476170 ] Kvicii.Yu commented on KAFKA-13592: --- [~dajac] hello, can i do this? > Fix flaky test

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

[ https://issues.apache.org/jira/browse/KAFKA-13592 ] Kvicii.Yu deleted comment on KAFKA-13592: --- was (Author: JIRAUSER283467): Can you provide a kafka version? > Fix flaky test > ControllerIntegrationTest.testTopicIdUpgradeAfterReassigningPartit

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

[ https://issues.apache.org/jira/browse/KAFKA-13592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17476165#comment-17476165 ] Kvicii.Yu commented on KAFKA-13592: --- Can you provide a kafka version? > Fix flaky tes

[GitHub] [kafka] satishd commented on a change in pull request #11390: [KAFKA-13369] Follower fetch protocol changes for tiered storage.

satishd commented on a change in pull request #11390: URL: https://github.com/apache/kafka/pull/11390#discussion_r784813247 ## File path: core/src/main/scala/kafka/server/ReplicaFetcherThread.scala ## @@ -386,11 +397,109 @@ class ReplicaFetcherThread(name: String, } /**

[jira] (KAFKA-12689) Remove deprecated EOS configs

[ https://issues.apache.org/jira/browse/KAFKA-12689 ] Kvicii.Yu deleted comment on KAFKA-12689: --- was (Author: JIRAUSER283467): [~loboxu] could i close this? > Remove deprecated EOS configs > - > > Key:

[jira] [Commented] (KAFKA-12689) Remove deprecated EOS configs

[ https://issues.apache.org/jira/browse/KAFKA-12689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17476157#comment-17476157 ] Kvicii.Yu commented on KAFKA-12689: --- [~loboxu] could i close this? > Remove deprecate

[GitHub] [kafka] soarez commented on pull request #9577: KAFKA-9837: KIP-589 new RPC for notifying controller log dir failure

soarez commented on pull request #9577: URL: https://github.com/apache/kafka/pull/9577#issuecomment-1013132683 @mumrah @hachikuji @bbejeck could someone have a look at this PR? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [kafka] dengziming commented on a change in pull request #11173: KAFKA-13509: Support max timestamp in GetOffsetShell

dengziming commented on a change in pull request #11173: URL: https://github.com/apache/kafka/pull/11173#discussion_r784854500 ## File path: core/src/main/scala/kafka/tools/GetOffsetShell.scala ## @@ -72,10 +73,10 @@ object GetOffsetShell { .ofType(c

[jira] [Commented] (KAFKA-13594) In TNPM Wireline Project, vulnerability found in Log4j-1.2.17.jar under KAFKA directory

[ https://issues.apache.org/jira/browse/KAFKA-13594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17476142#comment-17476142 ] Waseem commented on KAFKA-13594: In our project we have separate installation of project

[GitHub] [kafka] satishd commented on a change in pull request #11390: [KAFKA-13369] Follower fetch protocol changes for tiered storage.

satishd commented on a change in pull request #11390: URL: https://github.com/apache/kafka/pull/11390#discussion_r784817355 ## File path: core/src/main/scala/kafka/server/AbstractFetcherThread.scala ## @@ -715,6 +727,58 @@ abstract class AbstractFetcherThread(name: String,

[GitHub] [kafka] satishd commented on a change in pull request #11390: [KAFKA-13369] Follower fetch protocol changes for tiered storage.

satishd commented on a change in pull request #11390: URL: https://github.com/apache/kafka/pull/11390#discussion_r784813247 ## File path: core/src/main/scala/kafka/server/ReplicaFetcherThread.scala ## @@ -386,11 +397,109 @@ class ReplicaFetcherThread(name: String, } /**

[GitHub] [kafka] satishd commented on a change in pull request #11390: [KAFKA-13369] Follower fetch protocol changes for tiered storage.

satishd commented on a change in pull request #11390: URL: https://github.com/apache/kafka/pull/11390#discussion_r784801502 ## File path: core/src/main/scala/kafka/server/ReplicaFetcherThread.scala ## @@ -386,11 +397,109 @@ class ReplicaFetcherThread(name: String, } /**

[GitHub] [kafka] satishd commented on a change in pull request #11390: [KAFKA-13369] Follower fetch protocol changes for tiered storage.

satishd commented on a change in pull request #11390: URL: https://github.com/apache/kafka/pull/11390#discussion_r784793287 ## File path: core/src/main/scala/kafka/server/ReplicaFetcherThread.scala ## @@ -386,11 +397,109 @@ class ReplicaFetcherThread(name: String, } /**

[GitHub] [kafka] satishd commented on a change in pull request #11390: [KAFKA-13369] Follower fetch protocol changes for tiered storage.

satishd commented on a change in pull request #11390: URL: https://github.com/apache/kafka/pull/11390#discussion_r784793923 ## File path: core/src/main/scala/kafka/server/ReplicaFetcherThread.scala ## @@ -386,11 +396,76 @@ class ReplicaFetcherThread(name: String, } /**

[GitHub] [kafka] satishd commented on a change in pull request #11390: [KAFKA-13369] Follower fetch protocol changes for tiered storage.

satishd commented on a change in pull request #11390: URL: https://github.com/apache/kafka/pull/11390#discussion_r784793287 ## File path: core/src/main/scala/kafka/server/ReplicaFetcherThread.scala ## @@ -386,11 +397,109 @@ class ReplicaFetcherThread(name: String, } /**

[jira] [Commented] (KAFKA-5072) Kafka topics should allow custom metadata configs within some config namespace

[ https://issues.apache.org/jira/browse/KAFKA-5072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17476089#comment-17476089 ] Florian Albrecht commented on KAFKA-5072: - Really would like to see this implemen

[GitHub] [kafka] satishd commented on a change in pull request #11390: [KAFKA-13369] Follower fetch protocol changes for tiered storage.

satishd commented on a change in pull request #11390: URL: https://github.com/apache/kafka/pull/11390#discussion_r784772939 ## File path: core/src/main/scala/kafka/log/remote/RemoteLogManager.scala ## @@ -0,0 +1,287 @@ +/** + * Licensed to the Apache Software Foundation (ASF) u

[GitHub] [kafka] satishd commented on a change in pull request #11390: [KAFKA-13369] Follower fetch protocol changes for tiered storage.

satishd commented on a change in pull request #11390: URL: https://github.com/apache/kafka/pull/11390#discussion_r784770314 ## File path: core/src/main/scala/kafka/log/remote/RemoteLogManager.scala ## @@ -0,0 +1,287 @@ +/** + * Licensed to the Apache Software Foundation (ASF) u

[GitHub] [kafka] satishd commented on a change in pull request #11390: [KAFKA-13369] Follower fetch protocol changes for tiered storage.

satishd commented on a change in pull request #11390: URL: https://github.com/apache/kafka/pull/11390#discussion_r784768268 ## File path: core/src/main/scala/kafka/log/remote/RemoteIndexCache.scala ## @@ -0,0 +1,225 @@ +/** + * Licensed to the Apache Software Foundation (ASF) u

[GitHub] [kafka] satishd commented on a change in pull request #11390: [KAFKA-13369] Follower fetch protocol changes for tiered storage.

satishd commented on a change in pull request #11390: URL: https://github.com/apache/kafka/pull/11390#discussion_r784764008 ## File path: core/src/main/scala/kafka/log/remote/RemoteIndexCache.scala ## @@ -0,0 +1,225 @@ +/** + * Licensed to the Apache Software Foundation (ASF) u

[GitHub] [kafka] satishd commented on a change in pull request #11390: [KAFKA-13369] Follower fetch protocol changes for tiered storage.

satishd commented on a change in pull request #11390: URL: https://github.com/apache/kafka/pull/11390#discussion_r784753702 ## File path: core/src/main/scala/kafka/log/remote/RemoteIndexCache.scala ## @@ -0,0 +1,225 @@ +/** + * Licensed to the Apache Software Foundation (ASF) u

[GitHub] [kafka] satishd commented on a change in pull request #11390: [KAFKA-13369] Follower fetch protocol changes for tiered storage.

satishd commented on a change in pull request #11390: URL: https://github.com/apache/kafka/pull/11390#discussion_r784751134 ## File path: core/src/main/scala/kafka/log/remote/ClassLoaderAwareRemoteStorageManager.scala ## @@ -0,0 +1,76 @@ +/* + * Licensed to the Apache Software

[GitHub] [kafka] satishd commented on a change in pull request #11390: [KAFKA-13369] Follower fetch protocol changes for tiered storage.

satishd commented on a change in pull request #11390: URL: https://github.com/apache/kafka/pull/11390#discussion_r784750507 ## File path: core/src/main/scala/kafka/log/UnifiedLog.scala ## @@ -288,13 +294,24 @@ class UnifiedLog(@volatile var logStartOffset: Long, @volatile

[GitHub] [kafka] dajac commented on a change in pull request #11173: KAFKA-13509: Support max timestamp in GetOffsetShell

dajac commented on a change in pull request #11173: URL: https://github.com/apache/kafka/pull/11173#discussion_r784713919 ## File path: core/src/main/scala/kafka/tools/GetOffsetShell.scala ## @@ -72,10 +73,10 @@ object GetOffsetShell { .ofType(classO

[GitHub] [kafka] dajac commented on a change in pull request #11456: KAFKA-13351: Add possibility to write kafka headers in Kafka Console Producer

dajac commented on a change in pull request #11456: URL: https://github.com/apache/kafka/pull/11456#discussion_r784701638 ## File path: core/src/main/scala/kafka/tools/ConsoleProducer.scala ## @@ -264,39 +278,92 @@ object ConsoleProducer { var reader: BufferedReader = null

[GitHub] [kafka] dajac commented on pull request #11679: MINOR: make JoinGroupRequest and LeaveGroupRequest 'Reason' field ignorable

dajac commented on pull request #11679: URL: https://github.com/apache/kafka/pull/11679#issuecomment-1012953994 I merged the PR to trunk to fix the issue. We can follow up with another PR to add a unit test. -- This is an automated message from the Apache Git Service. To respond to the m

[GitHub] [kafka] dajac merged pull request #11679: MINOR: make JoinGroupRequest and LeaveGroupRequest 'Reason' field ignorable

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