[jira] [Created] (KAFKA-13596) ERROR Error while deleting segments for {topic} : java.nio.file.NoSuchFileException

shiyc created KAFKA-13596: - Summary: ERROR Error while deleting segments for {topic} : java.nio.file.NoSuchFileException Key: KAFKA-13596 URL: https://issues.apache.org/jira/browse/KAFKA-13596 Project: Kafka

[GitHub] [kafka] cmccabe commented on pull request #11677: KAFKA-13410 Add KRaft metadata.version for KIP-778

cmccabe commented on pull request #11677: URL: https://github.com/apache/kafka/pull/11677#issuecomment-1012661747 Do you want to split the `new VersionRange` -> `VersionRange.of` thing off into a separate PR? I like the change but it's kind of noisy (plus this would let us make some increm

[GitHub] [kafka] cmccabe commented on a change in pull request #11677: KAFKA-13410 Add KRaft metadata.version for KIP-778

cmccabe commented on a change in pull request #11677: URL: https://github.com/apache/kafka/pull/11677#discussion_r784440277 ## File path: core/src/main/scala/kafka/server/metadata/MetadataVersionManager.scala ## @@ -0,0 +1,104 @@ +/** + * Licensed to the Apache Software Founda

[GitHub] [kafka] cmccabe commented on a change in pull request #11677: KAFKA-13410 Add KRaft metadata.version for KIP-778

cmccabe commented on a change in pull request #11677: URL: https://github.com/apache/kafka/pull/11677#discussion_r784439265 ## File path: core/src/main/scala/kafka/server/metadata/BrokerMetadataPublisher.scala ## @@ -19,14 +19,15 @@ package kafka.server.metadata import kafk

[GitHub] [kafka] cmccabe commented on a change in pull request #11677: KAFKA-13410 Add KRaft metadata.version for KIP-778

cmccabe commented on a change in pull request #11677: URL: https://github.com/apache/kafka/pull/11677#discussion_r784439106 ## File path: core/src/main/scala/kafka/server/metadata/BrokerMetadataListener.scala ## @@ -118,9 +119,14 @@ class BrokerMetadataListener( }

[GitHub] [kafka] cmccabe commented on a change in pull request #11677: KAFKA-13410 Add KRaft metadata.version for KIP-778

cmccabe commented on a change in pull request #11677: URL: https://github.com/apache/kafka/pull/11677#discussion_r784438707 ## File path: core/src/main/scala/kafka/server/metadata/BrokerMetadataListener.scala ## @@ -73,7 +74,7 @@ class BrokerMetadataListener( /** * The

[GitHub] [kafka] cmccabe commented on a change in pull request #11677: KAFKA-13410 Add KRaft metadata.version for KIP-778

cmccabe commented on a change in pull request #11677: URL: https://github.com/apache/kafka/pull/11677#discussion_r784437638 ## File path: metadata/src/main/java/org/apache/kafka/metadata/MetadataRecordVersionResolver.java ## @@ -0,0 +1,25 @@ +/* + * Licensed to the Apache Soft

[GitHub] [kafka] cmccabe commented on a change in pull request #11677: KAFKA-13410 Add KRaft metadata.version for KIP-778

cmccabe commented on a change in pull request #11677: URL: https://github.com/apache/kafka/pull/11677#discussion_r784437102 ## File path: metadata/src/main/java/org/apache/kafka/metadata/MetadataVersion.java ## @@ -0,0 +1,41 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [kafka] cmccabe commented on a change in pull request #11677: KAFKA-13410 Add KRaft metadata.version for KIP-778

cmccabe commented on a change in pull request #11677: URL: https://github.com/apache/kafka/pull/11677#discussion_r784435597 ## File path: raft/src/main/java/org/apache/kafka/raft/internals/RecordsIterator.java ## @@ -240,6 +240,7 @@ private T readRecord(Readable input) {

[GitHub] [kafka] cmccabe commented on a change in pull request #11677: KAFKA-13410 Add KRaft metadata.version for KIP-778

cmccabe commented on a change in pull request #11677: URL: https://github.com/apache/kafka/pull/11677#discussion_r784434978 ## File path: core/src/main/scala/kafka/server/ReplicaManager.scala ## @@ -2107,7 +2107,7 @@ class ReplicaManager(val config: KafkaConfig, * @param de

[GitHub] [kafka] cmccabe commented on a change in pull request #11677: KAFKA-13410 Add KRaft metadata.version for KIP-778

cmccabe commented on a change in pull request #11677: URL: https://github.com/apache/kafka/pull/11677#discussion_r784434196 ## File path: core/src/main/scala/kafka/server/ControllerServer.scala ## @@ -160,11 +160,24 @@ class ControllerServer( alterConfigPolicy = Option(c

[GitHub] [kafka] cmccabe commented on a change in pull request #11677: KAFKA-13410 Add KRaft metadata.version for KIP-778

cmccabe commented on a change in pull request #11677: URL: https://github.com/apache/kafka/pull/11677#discussion_r784429730 ## File path: clients/src/main/resources/common/message/UpdateFeaturesRequest.json ## @@ -30,7 +30,11 @@ {"name": "MaxVersionLevel", "type": "int16

[GitHub] [kafka] cmccabe commented on a change in pull request #11677: KAFKA-13410 Add KRaft metadata.version for KIP-778

cmccabe commented on a change in pull request #11677: URL: https://github.com/apache/kafka/pull/11677#discussion_r784428620 ## File path: clients/src/main/java/org/apache/kafka/clients/admin/UpdateFeaturesOptions.java ## @@ -26,4 +26,14 @@ */ @InterfaceStability.Evolving p

[GitHub] [kafka] cmccabe commented on a change in pull request #11677: KAFKA-13410 Add KRaft metadata.version for KIP-778

cmccabe commented on a change in pull request #11677: URL: https://github.com/apache/kafka/pull/11677#discussion_r784427654 ## File path: clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java ## @@ -4245,12 +4245,24 @@ public UpdateFeaturesResult updateFea

[GitHub] [kafka] cmccabe commented on a change in pull request #11677: KAFKA-13410 Add KRaft metadata.version for KIP-778

cmccabe commented on a change in pull request #11677: URL: https://github.com/apache/kafka/pull/11677#discussion_r784426931 ## File path: clients/src/main/java/org/apache/kafka/clients/admin/FeatureUpdate.java ## @@ -42,6 +60,23 @@ public FeatureUpdate(final short maxVersionLe

[GitHub] [kafka] cmccabe commented on a change in pull request #11677: KAFKA-13410 Add KRaft metadata.version for KIP-778

cmccabe commented on a change in pull request #11677: URL: https://github.com/apache/kafka/pull/11677#discussion_r784426742 ## File path: clients/src/main/java/org/apache/kafka/clients/admin/FeatureUpdate.java ## @@ -24,6 +24,24 @@ public class FeatureUpdate { private fi

[GitHub] [kafka] cmccabe commented on a change in pull request #11677: KAFKA-13410 Add KRaft metadata.version for KIP-778

cmccabe commented on a change in pull request #11677: URL: https://github.com/apache/kafka/pull/11677#discussion_r784426548 ## File path: clients/src/main/java/org/apache/kafka/clients/admin/FeatureUpdate.java ## @@ -24,6 +24,24 @@ public class FeatureUpdate { private fi

[GitHub] [kafka] jeffkbkim opened a new pull request #11679: MINOR: make JoinGroupRequest and LeaveGroupRequest 'Reason' field ignorable

jeffkbkim opened a new pull request #11679: URL: https://github.com/apache/kafka/pull/11679 newer clients see errors when including reason in JoinGroupRequest to older broker: ``` Attempted to write a non-default reason at version 7. ``` make reason field in JoinGroupRequest an

[GitHub] [kafka] cmccabe commented on a change in pull request #11657: KAFKA-13552: Fix BROKER and BROKER_LOGGER in KRaft

cmccabe commented on a change in pull request #11657: URL: https://github.com/apache/kafka/pull/11657#discussion_r784398567 ## File path: core/src/main/scala/kafka/server/DynamicConfigManager.scala ## @@ -182,3 +188,52 @@ class DynamicConfigManager(private val zkClient: KafkaZ

[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=17475831#comment-17475831 ] Jun Rao commented on KAFKA-13594: - [~Waseem_bhura] : You can refer to [https://kafka.apa

[GitHub] [kafka] cmccabe commented on pull request #11678: Expose MetadataCache through testkit framework

cmccabe commented on pull request #11678: URL: https://github.com/apache/kafka/pull/11678#issuecomment-1012577468 Would it make more sense to expose the `KafkaBroker` object? We expose that in a lot of other cases, and it gives access to all the stuff -- This is an automated message from

[GitHub] [kafka] mumrah opened a new pull request #11678: Expose MetadataCache through testkit framework

mumrah opened a new pull request #11678: URL: https://github.com/apache/kafka/pull/11678 This cleans up a few things in ClusterInstance to make it more usable. Also fixes some old "raft" references. I also adjusted the parameter injection that ClusterTestExtensions is doing to allow

[GitHub] [kafka] cmccabe commented on a change in pull request #11657: KAFKA-13552: Fix BROKER and BROKER_LOGGER in KRaft

cmccabe commented on a change in pull request #11657: URL: https://github.com/apache/kafka/pull/11657#discussion_r784365893 ## File path: core/src/main/scala/kafka/server/MetadataSupport.scala ## @@ -56,11 +59,24 @@ sealed trait MetadataSupport { */ def ensureConsistentW

[GitHub] [kafka] cmccabe commented on a change in pull request #11657: KAFKA-13552: Fix BROKER and BROKER_LOGGER in KRaft

cmccabe commented on a change in pull request #11657: URL: https://github.com/apache/kafka/pull/11657#discussion_r784343554 ## File path: core/src/main/scala/kafka/server/DynamicConfigManager.scala ## @@ -182,3 +188,52 @@ class DynamicConfigManager(private val zkClient: KafkaZ

[GitHub] [kafka] cmccabe commented on a change in pull request #11657: KAFKA-13552: Fix BROKER and BROKER_LOGGER in KRaft

cmccabe commented on a change in pull request #11657: URL: https://github.com/apache/kafka/pull/11657#discussion_r784341498 ## File path: core/src/main/scala/kafka/server/ConfigAdminManager.scala ## @@ -0,0 +1,373 @@ +/** + * Licensed to the Apache Software Foundation (ASF) un

[GitHub] [kafka] cmccabe commented on a change in pull request #11657: KAFKA-13552: Fix BROKER and BROKER_LOGGER in KRaft

cmccabe commented on a change in pull request #11657: URL: https://github.com/apache/kafka/pull/11657#discussion_r784340295 ## File path: core/src/main/scala/kafka/server/ConfigAdminManager.scala ## @@ -0,0 +1,373 @@ +/** + * Licensed to the Apache Software Foundation (ASF) un

[GitHub] [kafka] cmccabe commented on a change in pull request #11657: KAFKA-13552: Fix BROKER and BROKER_LOGGER in KRaft

cmccabe commented on a change in pull request #11657: URL: https://github.com/apache/kafka/pull/11657#discussion_r784339091 ## File path: core/src/main/scala/kafka/server/ConfigAdminManager.scala ## @@ -0,0 +1,373 @@ +/** + * Licensed to the Apache Software Foundation (ASF) un

[GitHub] [kafka] cmccabe commented on a change in pull request #11657: KAFKA-13552: Fix BROKER and BROKER_LOGGER in KRaft

cmccabe commented on a change in pull request #11657: URL: https://github.com/apache/kafka/pull/11657#discussion_r78452 ## File path: core/src/main/scala/kafka/server/ConfigAdminManager.scala ## @@ -0,0 +1,373 @@ +/** + * Licensed to the Apache Software Foundation (ASF) un

[GitHub] [kafka] cmccabe commented on a change in pull request #11657: KAFKA-13552: Fix BROKER and BROKER_LOGGER in KRaft

cmccabe commented on a change in pull request #11657: URL: https://github.com/apache/kafka/pull/11657#discussion_r784329932 ## File path: core/src/main/scala/kafka/server/ConfigAdminManager.scala ## @@ -0,0 +1,373 @@ +/** + * Licensed to the Apache Software Foundation (ASF) un

[GitHub] [kafka] cmccabe commented on a change in pull request #11657: KAFKA-13552: Fix BROKER and BROKER_LOGGER in KRaft

cmccabe commented on a change in pull request #11657: URL: https://github.com/apache/kafka/pull/11657#discussion_r784328261 ## File path: core/src/main/scala/kafka/server/ConfigAdminManager.scala ## @@ -0,0 +1,373 @@ +/** + * Licensed to the Apache Software Foundation (ASF) un

[GitHub] [kafka] lmr3796 edited a comment on pull request #11669: MINOR: Replace if/else with match in KafkaZkClient#getPartitionAssignmentForTopics

lmr3796 edited a comment on pull request #11669: URL: https://github.com/apache/kafka/pull/11669#issuecomment-1012513464 Hi @ijuma sorry for the inconvenience! I accidentally deleted the branch. Just restored it. -- This is an automated message from the Apache Git Service. To respond

[GitHub] [kafka] lmr3796 commented on pull request #11669: MINOR: Replace if/else with match in KafkaZkClient#getPartitionAssignmentForTopics

lmr3796 commented on pull request #11669: URL: https://github.com/apache/kafka/pull/11669#issuecomment-1012513464 Hi @ijuma I -- 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] ijuma commented on pull request #11669: MINOR: Replace if/else with match in KafkaZkClient#getPartitionAssignmentForTopics

ijuma commented on pull request #11669: URL: https://github.com/apache/kafka/pull/11669#issuecomment-1012511094 @lmr3796 I was planning to merge the PR after triaging the test failures. -- This is an automated message from the Apache Git Service. To respond to the message, please log on t

[GitHub] [kafka] lmr3796 closed pull request #11669: MINOR: Replace if/else with match in KafkaZkClient#getPartitionAssignmentForTopics

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

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

dajac commented on pull request #11456: URL: https://github.com/apache/kafka/pull/11456#issuecomment-1012403673 I’ll make a pass tomorrow. Sorry for the delay. I could not do it sooner due to the holidays. -- This is an automated message from the Apache Git Service. To respond to the mes

[GitHub] [kafka] mumrah commented on a change in pull request #11677: KAFKA-13410 Add KRaft metadata.version for KIP-778

mumrah commented on a change in pull request #11677: URL: https://github.com/apache/kafka/pull/11677#discussion_r784226775 ## File path: metadata/src/main/java/org/apache/kafka/controller/ClusterControlManager.java ## @@ -251,7 +267,7 @@ public void deactivate() { L

[GitHub] [kafka] mumrah commented on a change in pull request #11677: KAFKA-13410 Add KRaft metadata.version for KIP-778

mumrah commented on a change in pull request #11677: URL: https://github.com/apache/kafka/pull/11677#discussion_r784225274 ## File path: core/src/main/scala/kafka/server/BrokerMetadataCheckpoint.scala ## @@ -94,11 +103,16 @@ class RawMetaProperties(val props: Properties = new

[GitHub] [kafka] mumrah commented on a change in pull request #11677: KAFKA-13410 Add KRaft metadata.version for KIP-778

mumrah commented on a change in pull request #11677: URL: https://github.com/apache/kafka/pull/11677#discussion_r784224825 ## File path: core/src/main/scala/kafka/server/BrokerMetadataCheckpoint.scala ## @@ -94,11 +103,16 @@ class RawMetaProperties(val props: Properties = new

[GitHub] [kafka] mumrah commented on a change in pull request #11677: KAFKA-13410 Add KRaft metadata.version for KIP-778

mumrah commented on a change in pull request #11677: URL: https://github.com/apache/kafka/pull/11677#discussion_r784223928 ## File path: clients/src/main/resources/common/message/UpdateFeaturesRequest.json ## @@ -30,7 +30,11 @@ {"name": "MaxVersionLevel", "type": "int16"

[GitHub] [kafka] mumrah opened a new pull request #11677: KAFKA-13410 Add KRaft metadata.version for KIP-778

mumrah opened a new pull request #11677: URL: https://github.com/apache/kafka/pull/11677 This is part of the implementation of KIP-778. More description TBD -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the U

[GitHub] [kafka] jsancio commented on a change in pull request #11657: KAFKA-13552: Fix BROKER and BROKER_LOGGER in KRaft

jsancio commented on a change in pull request #11657: URL: https://github.com/apache/kafka/pull/11657#discussion_r784146601 ## File path: core/src/main/scala/kafka/server/ConfigAdminManager.scala ## @@ -0,0 +1,373 @@ +/** + * Licensed to the Apache Software Foundation (ASF) un

[jira] [Resolved] (KAFKA-13593) ThrottledChannelReaper slows broker shutdown by multiple seconds

[ https://issues.apache.org/jira/browse/KAFKA-13593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Schlansker resolved KAFKA-13593. --- Resolution: Fixed > ThrottledChannelReaper slows broker shutdown by multiple seconds

[jira] [Commented] (KAFKA-13593) ThrottledChannelReaper slows broker shutdown by multiple seconds

[ https://issues.apache.org/jira/browse/KAFKA-13593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17475573#comment-17475573 ] Steven Schlansker commented on KAFKA-13593: --- Perfect! Glad I am not the only o

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

mimaison commented on a change in pull request #11456: URL: https://github.com/apache/kafka/pull/11456#discussion_r784199669 ## File path: core/src/test/scala/unit/kafka/tools/LineMessageReaderTest.scala ## @@ -0,0 +1,210 @@ +/** + * Licensed to the Apache Software Foundation (

[jira] (KAFKA-13575) Unwanted cleanup since log.retention.hours=-1 does not work

[ https://issues.apache.org/jira/browse/KAFKA-13575 ] joecqupt deleted comment on KAFKA-13575: -- was (Author: joecqupt): maybe you set both topic dynamic config `retention.ms` and  broker  dynamic config `log.retention.ms` ,  topic dynamic config p

[jira] [Commented] (KAFKA-13575) Unwanted cleanup since log.retention.hours=-1 does not work

[ https://issues.apache.org/jira/browse/KAFKA-13575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17475539#comment-17475539 ] joecqupt commented on KAFKA-13575: -- maybe you set both topic dynamic config `retention.

[jira] [Comment Edited] (KAFKA-13593) ThrottledChannelReaper slows broker shutdown by multiple seconds

[ https://issues.apache.org/jira/browse/KAFKA-13593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17475474#comment-17475474 ] Lucas Bradstreet edited comment on KAFKA-13593 at 1/13/22, 3:58 PM: --

[jira] [Commented] (KAFKA-13593) ThrottledChannelReaper slows broker shutdown by multiple seconds

[ https://issues.apache.org/jira/browse/KAFKA-13593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17475474#comment-17475474 ] Lucas Bradstreet commented on KAFKA-13593: -- Thanks for reporting [~stevenschlan

[GitHub] [kafka] bfncs edited a comment on pull request #7082: KAFKA-8659: SetSchemaMetadata SMT fails on records with null value and schema

bfncs edited a comment on pull request #7082: URL: https://github.com/apache/kafka/pull/7082#issuecomment-1012224319 I finally adopted the patch to the current trunk. The CI test run here failed though, while at least all tests from the related connect transforms package run for me locally

[GitHub] [kafka] bfncs commented on pull request #7082: KAFKA-8659: SetSchemaMetadata SMT fails on records with null value and schema

bfncs commented on pull request #7082: URL: https://github.com/apache/kafka/pull/7082#issuecomment-1012224319 I finally adopted the patch to the current trunk. The CI test run here failed though, while at least all tests from the related connect transforms package run for me locally. Can a

[jira] [Resolved] (KAFKA-13451) Add reason to JoinGroupRequest and LeaveGroupRequest

[ https://issues.apache.org/jira/browse/KAFKA-13451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-13451. - Fix Version/s: 3.2.0 Reviewer: David Jacot Resolution: Fixed > Add reason to Joi

[jira] [Resolved] (KAFKA-13496) Add reason to LeaveGroupRequest

[ https://issues.apache.org/jira/browse/KAFKA-13496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-13496. - Fix Version/s: 3.2.0 Reviewer: David Jacot Resolution: Fixed > Add reason to Lea

[jira] [Resolved] (KAFKA-13495) Add reason to JoinGroupRequest

[ https://issues.apache.org/jira/browse/KAFKA-13495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-13495. - Fix Version/s: 3.2.0 Reviewer: David Jacot Resolution: Fixed > Add reason to Joi

[GitHub] [kafka] dajac merged pull request #11571: KAFKA-13496: Add reason to LeaveGroupRequest (KIP-800)

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

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

rondagostino commented on a change in pull request #11616: URL: https://github.com/apache/kafka/pull/11616#discussion_r784034488 ## File path: config/kraft/README.md ## @@ -35,6 +35,9 @@ Formatting /tmp/kraft-combined-logs If you are using multiple nodes, then you should run

[GitHub] [kafka] dajac merged pull request #11566: KAFKA-13495: Add reason to JoinGroupRequest (KIP-800)

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

[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-1012204127 @rondagostino @cmccabe , please help review. Thanks. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use th

[GitHub] [kafka] ahmed3465 edited a comment on pull request #6097: KAFKA-5061 - Make default Worker Task client IDs distinct

ahmed3465 edited a comment on pull request #6097: URL: https://github.com/apache/kafka/pull/6097#issuecomment-1007159144 Is there a way I can alter the code and share the Mbean sensor across multiple consumers using the same client-id ? We have an auto-scaling Kafka connect cluster which

[jira] [Commented] (KAFKA-2953) Kafka documentation is really wide

[ https://issues.apache.org/jira/browse/KAFKA-2953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17475380#comment-17475380 ] Kvicii.Yu commented on KAFKA-2953: -- I think it's also important to have multilingual doc

[jira] [Commented] (KAFKA-9135) Kafka producer/consumer are creating too many open file

[ https://issues.apache.org/jira/browse/KAFKA-9135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17475375#comment-17475375 ] Kvicii.Yu commented on KAFKA-9135: -- Do you know your machine's corpus handle number conf

[jira] [Commented] (KAFKA-7148) Kafka load log very slow after goes down with outOfMemoryError

[ https://issues.apache.org/jira/browse/KAFKA-7148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17475371#comment-17475371 ] Kvicii.Yu commented on KAFKA-7148: -- This should appear when rebuilding the index, you ca

[GitHub] [kafka] patrickstuedi opened a new pull request #11676: feat: checkpoint position in state stores

patrickstuedi opened a new pull request #11676: URL: https://github.com/apache/kafka/pull/11676 *More detailed description of your change, if necessary. The PR title and PR message become the squashed commit message, so use a separate comment to ping reviewers.* *Summary of t

[GitHub] [kafka] dajac commented on pull request #11671: KAFKA-13388; Kafka Producer nodes stuck in CHECKING_API_VERSIONS

dajac commented on pull request #11671: URL: https://github.com/apache/kafka/pull/11671#issuecomment-1012033147 Failed tests are unrelated: ``` Build / JDK 17 and Scala 2.13 / testDescribeUnderMinIsrPartitionsMixed() – kafka.admin.TopicCommandIntegrationTest ``` -- This is an au

[jira] [Commented] (KAFKA-13452) MM2 creates invalid checkpoint when offset mapping is not available

[ https://issues.apache.org/jira/browse/KAFKA-13452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17475255#comment-17475255 ] Praveen Sinha commented on KAFKA-13452: --- This looks related to this one - https:/

[GitHub] [kafka] tombentley commented on pull request #8575: KAFKA-8713 KIP-581 Add accept.optional.null to solve optional null

tombentley commented on pull request #8575: URL: https://github.com/apache/kafka/pull/8575#issuecomment-1012011876 @pan3793 As far as I can see you never started a VOTE thread for your KIP. If this is something you're still interested in working on it would be good to get a vote started. I

[jira] [Created] (KAFKA-13595) Allow producing records with null values in Kafka Console Producer

Mickael Maison created KAFKA-13595: -- Summary: Allow producing records with null values in Kafka Console Producer Key: KAFKA-13595 URL: https://issues.apache.org/jira/browse/KAFKA-13595 Project: Kafka

[jira] [Resolved] (KAFKA-7589) Allow configuring num.network.threads per listener

[ https://issues.apache.org/jira/browse/KAFKA-7589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison resolved KAFKA-7589. --- Fix Version/s: 3.2.0 Resolution: Fixed > Allow configuring num.network.threads per lis

[GitHub] [kafka] mimaison merged pull request #11560: KAFKA-7589: Allow configuring network threads per listener

mimaison merged pull request #11560: URL: https://github.com/apache/kafka/pull/11560 -- 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-13594) In TNPM Wireline Project, vulnerability found in Log4j-1.2.17.jar under KAFKA directory

Waseem created KAFKA-13594: -- Summary: In TNPM Wireline Project, vulnerability found in Log4j-1.2.17.jar under KAFKA directory Key: KAFKA-13594 URL: https://issues.apache.org/jira/browse/KAFKA-13594 Project:

[GitHub] [kafka] dajac commented on a change in pull request #11666: KAFKA-13591; Fix flaky test `ControllerIntegrationTest.testTopicIdCreatedOnUpgrade`

dajac commented on a change in pull request #11666: URL: https://github.com/apache/kafka/pull/11666#discussion_r783736527 ## File path: core/src/test/scala/unit/kafka/controller/ControllerIntegrationTest.scala ## @@ -1127,27 +1127,29 @@ class ControllerIntegrationTest extends