[jira] [Updated] (KAFKA-13512) topicIdsToNames and topicNamesToIds allocate unnecessary maps

[ https://issues.apache.org/jira/browse/KAFKA-13512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot updated KAFKA-13512: Fix Version/s: 3.1.0 > topicIdsToNames and topicNamesToIds allocate unnecessary maps >

[GitHub] [kafka] itweixiang removed a comment on pull request #9902: KAFKA-12193: Re-resolve IPs after a client disconnects

itweixiang removed a comment on pull request #9902: URL: https://github.com/apache/kafka/pull/9902#issuecomment-987738907 hi bob-barrett , I hava a quetion about your issue ,can you help me ? our kafka are deloying in k8s , where kafka cluster restart , result in producer and consumer

[GitHub] [kafka] showuon opened a new pull request #11578: KAFKA-13514: reduce consumer count and timeout to speed up the test

showuon opened a new pull request #11578: URL: https://github.com/apache/kafka/pull/11578 Reduce the timeout from 60s to 40s, and reduce the consumer count from 2000 -> 1000. In local env, before change, the time took 44s, after change, time took 16s. If before change, in jenkins we

[jira] [Created] (KAFKA-13517) Add ConfigurationKeys to ConfigResource class

Vikas Singh created KAFKA-13517: --- Summary: Add ConfigurationKeys to ConfigResource class Key: KAFKA-13517 URL: https://issues.apache.org/jira/browse/KAFKA-13517 Project: Kafka Issue Type:

[GitHub] [kafka] tamara-skokova commented on pull request #11573: KAFKA-13507: GlobalProcessor ignores user specified names

tamara-skokova commented on pull request #11573: URL: https://github.com/apache/kafka/pull/11573#issuecomment-988484139 @showuon, thanks, added a test that verifies the default names -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [kafka] jeffkbkim edited a comment on pull request #11571: KAFKA-13496: add reason to LeaveGroupRequest

jeffkbkim edited a comment on pull request #11571: URL: https://github.com/apache/kafka/pull/11571#issuecomment-988460630 -- 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.

[GitHub] [kafka] jeffkbkim edited a comment on pull request #11571: KAFKA-13496: add reason to LeaveGroupRequest

jeffkbkim edited a comment on pull request #11571: URL: https://github.com/apache/kafka/pull/11571#issuecomment-988460630 tests calling `adminClient.removeMembersFromConsumerGroup` are failing: ``` ERROR [KafkaApi-2] Unexpected error handling request RequestHeader(apiKey=LEAVE_GROUP,

[GitHub] [kafka] jeffkbkim commented on pull request #11571: KAFKA-13496: add reason to LeaveGroupRequest

jeffkbkim commented on pull request #11571: URL: https://github.com/apache/kafka/pull/11571#issuecomment-988460630 tests calling `adminClient.removeMembersFromConsumerGroup` are failing: ``` ERROR [KafkaApi-2] Unexpected error handling request RequestHeader(apiKey=LEAVE_GROUP,

[GitHub] [kafka] showuon commented on a change in pull request #11573: KAFKA-13507: GlobalProcessor ignores user specified names

showuon commented on a change in pull request #11573: URL: https://github.com/apache/kafka/pull/11573#discussion_r764516991 ## File path: streams/src/test/java/org/apache/kafka/streams/StreamsBuilderTest.java ## @@ -998,6 +999,23 @@ public void

[jira] [Comment Edited] (KAFKA-10503) MockProducer doesn't throw ClassCastException when no partition for topic

[ https://issues.apache.org/jira/browse/KAFKA-10503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454673#comment-17454673 ] Dennis Hunziker edited comment on KAFKA-10503 at 12/8/21, 2:58 AM: ---

[jira] [Assigned] (KAFKA-13514) Flakey test StickyAssignorTest

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

[GitHub] [kafka] Loyilee closed pull request #10781: MINOR: Reduce duplicate authentication check

Loyilee closed pull request #10781: URL: https://github.com/apache/kafka/pull/10781 -- 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:

[GitHub] [kafka] Loyilee closed pull request #10601: KAFKA-12723: Fix potential NPE in HashTier

Loyilee closed pull request #10601: URL: https://github.com/apache/kafka/pull/10601 -- 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:

[GitHub] [kafka] ableegoldman commented on pull request #11562: KAFKA-12648: extend IQ APIs to work with named topologies

ableegoldman commented on pull request #11562: URL: https://github.com/apache/kafka/pull/11562#issuecomment-988400580 Hey @tolgadur can we also add one more thing to this -- see https://github.com/tolgadur/kafka/pull/1 -- This is an automated message from the Apache Git Service. To

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

florin-akermann commented on pull request #11456: URL: https://github.com/apache/kafka/pull/11456#issuecomment-988371209 Hi again, @dajac @mimaison I made the adjustments based on your inputs. -- This is an automated message from the Apache Git Service. To respond to

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

florin-akermann commented on a change in pull request #11456: URL: https://github.com/apache/kafka/pull/11456#discussion_r764457132 ## File path: core/src/main/scala/kafka/tools/ConsoleProducer.scala ## @@ -206,11 +210,25 @@ object ConsoleProducer { .describedAs("size")

[jira] [Created] (KAFKA-13516) Connection level metrics are not closed

Aman Agarwal created KAFKA-13516: Summary: Connection level metrics are not closed Key: KAFKA-13516 URL: https://issues.apache.org/jira/browse/KAFKA-13516 Project: Kafka Issue Type: Bug

[GitHub] [kafka] cmccabe opened a new pull request #11577: KAFKA-13515: Fix KRaft config validation issues

cmccabe opened a new pull request #11577: URL: https://github.com/apache/kafka/pull/11577 Require that topics exist before topic configurations can be created for them. Merge the code from ConfigurationControlManager#checkConfigResource into ControllerConfigurationValidator to

[jira] [Created] (KAFKA-13515) Fix KRaft config validation issues

Colin McCabe created KAFKA-13515: Summary: Fix KRaft config validation issues Key: KAFKA-13515 URL: https://issues.apache.org/jira/browse/KAFKA-13515 Project: Kafka Issue Type: Bug

[GitHub] [kafka] rondagostino commented on a change in pull request #11503: KAFKA-13456: Tighten KRaft config checks/constraints

rondagostino commented on a change in pull request #11503: URL: https://github.com/apache/kafka/pull/11503#discussion_r764387735 ## File path: core/src/main/scala/kafka/server/KafkaConfig.scala ## @@ -2018,12 +2025,103 @@ class KafkaConfig private(doLog: Boolean, val props:

[GitHub] [kafka] dajac commented on pull request #11576: KAFKA-13512: topicIdsToNames and topicNamesToIds allocate unnecessary maps

dajac commented on pull request #11576: URL: https://github.com/apache/kafka/pull/11576#issuecomment-988280848 The MetadataSnapshot is immutable so this seems fine to me as well. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [kafka] C0urante commented on a change in pull request #11046: KAFKA-12980: Return empty record batch from Consumer::poll when position advances due to aborted transactions

C0urante commented on a change in pull request #11046: URL: https://github.com/apache/kafka/pull/11046#discussion_r764381476 ## File path: clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java ## @@ -725,17 +725,13 @@ public void

[GitHub] [kafka] jolshan opened a new pull request #11576: KAFKA-13512: topicIdsToNames and topicNamesToIds allocate unnecessary maps

jolshan opened a new pull request #11576: URL: https://github.com/apache/kafka/pull/11576 We are creating a new map unnecessarily for these methods. Remove the extra map creation and simply wrap in unmodifiable map. I've also added a benchmark for the map method. Here are some

[GitHub] [kafka] rondagostino commented on a change in pull request #11503: KAFKA-13456: Tighten KRaft config checks/constraints

rondagostino commented on a change in pull request #11503: URL: https://github.com/apache/kafka/pull/11503#discussion_r764369935 ## File path: core/src/main/scala/kafka/server/KafkaConfig.scala ## @@ -2018,12 +2025,103 @@ class KafkaConfig private(doLog: Boolean, val props:

[GitHub] [kafka] rondagostino commented on a change in pull request #11503: KAFKA-13456: Tighten KRaft config checks/constraints

rondagostino commented on a change in pull request #11503: URL: https://github.com/apache/kafka/pull/11503#discussion_r764367910 ## File path: core/src/main/scala/kafka/server/KafkaConfig.scala ## @@ -2018,12 +2025,103 @@ class KafkaConfig private(doLog: Boolean, val props:

[GitHub] [kafka] rondagostino commented on a change in pull request #11503: KAFKA-13456: Tighten KRaft config checks/constraints

rondagostino commented on a change in pull request #11503: URL: https://github.com/apache/kafka/pull/11503#discussion_r764367513 ## File path: core/src/test/scala/unit/kafka/server/KafkaConfigTest.scala ## @@ -1000,46 +1139,78 @@ class KafkaConfigTest { } } - def

[GitHub] [kafka] bbejeck commented on pull request #11573: KAFKA-13507: GlobalProcessor ignores user specified names

bbejeck commented on pull request #11573: URL: https://github.com/apache/kafka/pull/11573#issuecomment-988225508 Failures unrelated to this PR - kicked off another build - JDK 8 and Scala 2.12 / kafka.admin.LeaderElectionCommandTest.[1] Type=Raft, Name=testTopicPartition,

[GitHub] [kafka] vvcephei commented on a change in pull request #11513: feat: Write and restore position to/from changelog

vvcephei commented on a change in pull request #11513: URL: https://github.com/apache/kafka/pull/11513#discussion_r764279791 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextImpl.java ## @@ -110,17 +121,27 @@ public

[GitHub] [kafka] vvcephei commented on a change in pull request #11513: feat: Write and restore position to/from changelog

vvcephei commented on a change in pull request #11513: URL: https://github.com/apache/kafka/pull/11513#discussion_r764278336 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/ChangelogRecordDeserializationHelper.java ## @@ -0,0 +1,75 @@ +/* + *

[GitHub] [kafka] vvcephei commented on a change in pull request #11513: feat: Write and restore position to/from changelog

vvcephei commented on a change in pull request #11513: URL: https://github.com/apache/kafka/pull/11513#discussion_r764277280 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/ChangelogRecordDeserializationHelper.java ## @@ -0,0 +1,75 @@ +/* + *

[GitHub] [kafka] vvcephei commented on a change in pull request #11513: feat: Write and restore position to/from changelog

vvcephei commented on a change in pull request #11513: URL: https://github.com/apache/kafka/pull/11513#discussion_r764271813 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/ChangelogRecordDeserializationHelper.java ## @@ -0,0 +1,75 @@ +/* + *

[GitHub] [kafka] hachikuji commented on a change in pull request #11046: KAFKA-12980: Return empty record batch from Consumer::poll when position advances due to aborted transactions

hachikuji commented on a change in pull request #11046: URL: https://github.com/apache/kafka/pull/11046#discussion_r764255533 ## File path: clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java ## @@ -725,17 +725,13 @@ public void

[GitHub] [kafka] hachikuji commented on a change in pull request #11503: KAFKA-13456: Tighten KRaft config checks/constraints

hachikuji commented on a change in pull request #11503: URL: https://github.com/apache/kafka/pull/11503#discussion_r764232658 ## File path: core/src/main/scala/kafka/server/KafkaConfig.scala ## @@ -1959,10 +1962,26 @@ class KafkaConfig private(doLog: Boolean, val props:

[GitHub] [kafka] hachikuji commented on a change in pull request #11503: KAFKA-13456: Tighten KRaft config checks/constraints

hachikuji commented on a change in pull request #11503: URL: https://github.com/apache/kafka/pull/11503#discussion_r764221288 ## File path: core/src/main/scala/kafka/server/KafkaConfig.scala ## @@ -748,7 +749,8 @@ object KafkaConfig { "Different security (SSL and SASL)

[GitHub] [kafka] hachikuji commented on a change in pull request #11503: KAFKA-13456: Tighten KRaft config checks/constraints

hachikuji commented on a change in pull request #11503: URL: https://github.com/apache/kafka/pull/11503#discussion_r764232658 ## File path: core/src/main/scala/kafka/server/KafkaConfig.scala ## @@ -1959,10 +1962,26 @@ class KafkaConfig private(doLog: Boolean, val props:

[jira] [Created] (KAFKA-13514) Flakey test StickyAssignorTest

Matthias J. Sax created KAFKA-13514: --- Summary: Flakey test StickyAssignorTest Key: KAFKA-13514 URL: https://issues.apache.org/jira/browse/KAFKA-13514 Project: Kafka Issue Type: Test

[jira] [Created] (KAFKA-13513) Flaky test AdjustStreamThreadCountTest

Matthias J. Sax created KAFKA-13513: --- Summary: Flaky test AdjustStreamThreadCountTest Key: KAFKA-13513 URL: https://issues.apache.org/jira/browse/KAFKA-13513 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-13512) topicIdsToNames and topicNamesToIds allocate unnecessary maps

Justine Olshan created KAFKA-13512: -- Summary: topicIdsToNames and topicNamesToIds allocate unnecessary maps Key: KAFKA-13512 URL: https://issues.apache.org/jira/browse/KAFKA-13512 Project: Kafka

[GitHub] [kafka] cadonna merged pull request #11561: MINOR: Bump version of grgit to 4.1.1

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

[GitHub] [kafka] cadonna merged pull request #11574: MINOR: Fix internal topic manager tests

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

[GitHub] [kafka] cadonna commented on pull request #11574: MINOR: Fix internal topic manager tests

cadonna commented on pull request #11574: URL: https://github.com/apache/kafka/pull/11574#issuecomment-988124933 Test failures are not related. -- 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

[GitHub] [kafka] C0urante commented on a change in pull request #11046: KAFKA-12980: Return empty record batch from Consumer::poll when position advances due to aborted transactions

C0urante commented on a change in pull request #11046: URL: https://github.com/apache/kafka/pull/11046#discussion_r764163807 ## File path: clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java ## @@ -725,17 +725,13 @@ public void

[GitHub] [kafka] C0urante commented on a change in pull request #11046: KAFKA-12980: Return empty record batch from Consumer::poll when position advances due to aborted transactions

C0urante commented on a change in pull request #11046: URL: https://github.com/apache/kafka/pull/11046#discussion_r764161918 ## File path: clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java ## @@ -1176,7 +1176,8 @@ public void assign(Collection

[GitHub] [kafka] rondagostino commented on a change in pull request #11503: KAFKA-13456: Tighten KRaft config checks/constraints

rondagostino commented on a change in pull request #11503: URL: https://github.com/apache/kafka/pull/11503#discussion_r764161713 ## File path: core/src/main/scala/kafka/server/KafkaConfig.scala ## @@ -1959,10 +1961,18 @@ class KafkaConfig private(doLog: Boolean, val props:

[GitHub] [kafka] C0urante commented on a change in pull request #11046: KAFKA-12980: Return empty record batch from Consumer::poll when position advances due to aborted transactions

C0urante commented on a change in pull request #11046: URL: https://github.com/apache/kafka/pull/11046#discussion_r764161599 ## File path: clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java ## @@ -1176,7 +1176,8 @@ public void assign(Collection

[GitHub] [kafka] ccding commented on a change in pull request #11345: Allow empty last segment to have missing offset index during recovery

ccding commented on a change in pull request #11345: URL: https://github.com/apache/kafka/pull/11345#discussion_r764130805 ## File path: core/src/main/scala/kafka/log/UnifiedLog.scala ## @@ -1498,28 +1498,44 @@ class UnifiedLog(@volatile var logStartOffset: Long,

[GitHub] [kafka] twobeeb commented on pull request #11575: KAFKA-13511: Update TimestampConverter support unix epoch as millis, micros, and seconds

twobeeb commented on pull request #11575: URL: https://github.com/apache/kafka/pull/11575#issuecomment-988049565 @mimaison @rhauch before considering going further with this PR, any chance I could to get your opinion on this subject ? The main idea behind this PR is that Avro

[GitHub] [kafka] twobeeb opened a new pull request #11575: KAFKA-13511: Update TimestampConverter support unix epoch as millis, micros, and seconds

twobeeb opened a new pull request #11575: URL: https://github.com/apache/kafka/pull/11575 Currently, the SMT TimestampConverter can convert Timestamp from either source String, Long or Date into target String, Long or Date. The problem is that Long source or target is required to be

[jira] [Updated] (KAFKA-13511) Update TimestampConverter SMT to support unix epoch as millis, micros, and seconds

[ https://issues.apache.org/jira/browse/KAFKA-13511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Julien Chanaud updated KAFKA-13511: --- Description: Currently, the SMT TimestampConverter can convert Timestamp from either source

[jira] [Updated] (KAFKA-13511) Update TimestampConverter SMT to support unix epoch as millis, micros, and seconds

[ https://issues.apache.org/jira/browse/KAFKA-13511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Julien Chanaud updated KAFKA-13511: --- Description: Currently, the SMT TimestampConverter can convert Timestamp from either source

[jira] [Commented] (KAFKA-10503) MockProducer doesn't throw ClassCastException when no partition for topic

[ https://issues.apache.org/jira/browse/KAFKA-10503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454673#comment-17454673 ] Dennis Hunziker commented on KAFKA-10503: - This change did break our tests. When using the

[jira] [Updated] (KAFKA-13511) Update TimestampConverter SMT to support unix epoch as millis, micros, and seconds

[ https://issues.apache.org/jira/browse/KAFKA-13511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Julien Chanaud updated KAFKA-13511: --- Description: Currently, the SMT TimestampConverter can convert Timestamp from either source

[jira] [Created] (KAFKA-13511) Update TimestampConverter SMT to support unix epoch as millis, micros, and seconds

Julien Chanaud created KAFKA-13511: -- Summary: Update TimestampConverter SMT to support unix epoch as millis, micros, and seconds Key: KAFKA-13511 URL: https://issues.apache.org/jira/browse/KAFKA-13511

[GitHub] [kafka] showuon commented on a change in pull request #11566: KAFKA-13495: add reason to JoinGroupRequest

showuon commented on a change in pull request #11566: URL: https://github.com/apache/kafka/pull/11566#discussion_r764003611 ## File path: clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java ## @@ -2303,18 +2303,24 @@ public ConsumerGroupMetadata

[GitHub] [kafka] vpapavas commented on a change in pull request #11513: feat: Write and restore position to/from changelog

vpapavas commented on a change in pull request #11513: URL: https://github.com/apache/kafka/pull/11513#discussion_r764012303 ## File path: streams/src/test/java/org/apache/kafka/streams/integration/ConsistencyVectorIntegrationTest.java ## @@ -0,0 +1,236 @@ +/* + * Licensed to

[GitHub] [kafka] cadonna opened a new pull request #11574: MINOR: Fix internal topic manager tests

cadonna opened a new pull request #11574: URL: https://github.com/apache/kafka/pull/11574 When the unit tests of the internal topic manager test are executed on a slow machine (like sometimes in automatic builds) they sometimes fail with a timeout exception instead of the expected

[jira] [Comment Edited] (KAFKA-13077) Replication failing after unclean shutdown of ZK and all brokers

[ https://issues.apache.org/jira/browse/KAFKA-13077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454611#comment-17454611 ] Shivakumar Kedlaya edited comment on KAFKA-13077 at 12/7/21, 12:05 PM:

[jira] [Comment Edited] (KAFKA-13077) Replication failing after unclean shutdown of ZK and all brokers

[ https://issues.apache.org/jira/browse/KAFKA-13077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454611#comment-17454611 ] Shivakumar Kedlaya edited comment on KAFKA-13077 at 12/7/21, 12:03 PM:

[GitHub] [kafka] tamara-skokova opened a new pull request #11573: KAFKA-13507: GlobalProcessor ignores user specified names

tamara-skokova opened a new pull request #11573: URL: https://github.com/apache/kafka/pull/11573 Use the name specified via `consumed` parameter in `InternalStreamsBuilder#addGlobalStore` method for initializing the source name and processor name. If not specified, the names are

[jira] [Commented] (KAFKA-13077) Replication failing after unclean shutdown of ZK and all brokers

[ https://issues.apache.org/jira/browse/KAFKA-13077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454611#comment-17454611 ] Shivakumar Kedlaya commented on KAFKA-13077: [~causton] we have a similar issue in our

[GitHub] [kafka] mimaison opened a new pull request #11572: KAFKA-13510: Connect APIs to list all connector plugins and retrieve …

mimaison opened a new pull request #11572: URL: https://github.com/apache/kafka/pull/11572 …their configdefs Implements KIP-769 ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI build status

[jira] [Created] (KAFKA-13510) KIP-769: Connect APIs to list all connector plugins and retrieve their configuration definitions

Mickael Maison created KAFKA-13510: -- Summary: KIP-769: Connect APIs to list all connector plugins and retrieve their configuration definitions Key: KAFKA-13510 URL:

[GitHub] [kafka] patrickstuedi commented on a change in pull request #11513: feat: Write and restore position to/from changelog

patrickstuedi commented on a change in pull request #11513: URL: https://github.com/apache/kafka/pull/11513#discussion_r763810277 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/ChangelogRecordDeserializationHelper.java ## @@ -0,0 +1,75 @@ +/*

[GitHub] [kafka] itweixiang commented on a change in pull request #9902: KAFKA-12193: Re-resolve IPs after a client disconnects

itweixiang commented on a change in pull request #9902: URL: https://github.com/apache/kafka/pull/9902#discussion_r763795681 ## File path: clients/src/test/java/org/apache/kafka/clients/NetworkClientTest.java ## @@ -81,6 +85,19 @@ private final NetworkClient

[GitHub] [kafka] itweixiang commented on pull request #9902: KAFKA-12193: Re-resolve IPs after a client disconnects

itweixiang commented on pull request #9902: URL: https://github.com/apache/kafka/pull/9902#issuecomment-987738907 hi bob-barrett , I hava a quetion about your issue ,can you help me ? our kafka are deloying in k8s , where kafka cluster restart , result in producer and consumer will

[GitHub] [kafka] xuchenxin commented on pull request #9902: KAFKA-12193: Re-resolve IPs after a client disconnects

xuchenxin commented on pull request #9902: URL: https://github.com/apache/kafka/pull/9902#issuecomment-987730869 您好，我已收到您的来信，会尽快回复。谢谢！ -- 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

[GitHub] [kafka] itweixiang commented on a change in pull request #9902: KAFKA-12193: Re-resolve IPs after a client disconnects

itweixiang commented on a change in pull request #9902: URL: https://github.com/apache/kafka/pull/9902#discussion_r763795681 ## File path: clients/src/test/java/org/apache/kafka/clients/NetworkClientTest.java ## @@ -81,6 +85,19 @@ private final NetworkClient

[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_r763752790 ## File path: core/src/main/scala/kafka/tools/GetOffsetShell.scala ## @@ -72,10 +73,10 @@ object GetOffsetShell {

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

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