[GitHub] [kafka] cmccabe commented on pull request #11649: KAFKA-13646: Implement KIP-801: KRaft authorizer

cmccabe commented on pull request #11649: URL: https://github.com/apache/kafka/pull/11649#issuecomment-1033469240 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 th

[jira] [Commented] (KAFKA-13422) Even if the correct username and password are configured, when ClientBroker or KafkaClient tries to establish a SASL connection to ServerBroker, an exception is thrown

[ https://issues.apache.org/jira/browse/KAFKA-13422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489372#comment-17489372 ] RivenSun commented on KAFKA-13422: -- Hi [~rsivaram]  [~ijuma] , [~guozhang]  can you gi

[GitHub] [kafka] dajac commented on a change in pull request #11688: KAFKA-13435; Static membership protocol should let the leader skip assignment (KIP-814)

dajac commented on a change in pull request #11688: URL: https://github.com/apache/kafka/pull/11688#discussion_r802417366 ## File path: clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java ## @@ -696,8 +698,12 @@ public void handle(JoinGro

[GitHub] [kafka] dajac commented on a change in pull request #11688: KAFKA-13435; Static membership protocol should let the leader skip assignment (KIP-814)

dajac commented on a change in pull request #11688: URL: https://github.com/apache/kafka/pull/11688#discussion_r802450152 ## File path: clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinatorTest.java ## @@ -386,15 +386,39 @@ public void testPerf

[GitHub] [kafka] dajac commented on a change in pull request #11688: KAFKA-13435; Static membership protocol should let the leader skip assignment (KIP-814)

dajac commented on a change in pull request #11688: URL: https://github.com/apache/kafka/pull/11688#discussion_r802484108 ## File path: clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinatorTest.java ## @@ -1550,6 +1573,34 @@ public void testMeta

[jira] [Commented] (KAFKA-13658) Upgrade vulnerable dependencies jan 2022

[ https://issues.apache.org/jira/browse/KAFKA-13658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489429#comment-17489429 ] Dominique Mongelli commented on KAFKA-13658: Hi, For information here is th

[GitHub] [kafka] dajac commented on a change in pull request #11688: KAFKA-13435; Static membership protocol should let the leader skip assignment (KIP-814)

dajac commented on a change in pull request #11688: URL: https://github.com/apache/kafka/pull/11688#discussion_r802514285 ## File path: clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java ## @@ -655,11 +667,8 @@ private void maybeUpdateGr

[GitHub] [kafka] dajac commented on a change in pull request #11688: KAFKA-13435; Static membership protocol should let the leader skip assignment (KIP-814)

dajac commented on a change in pull request #11688: URL: https://github.com/apache/kafka/pull/11688#discussion_r802515290 ## File path: core/src/test/scala/integration/kafka/api/PlaintextConsumerTest.scala ## @@ -1791,4 +1793,33 @@ class PlaintextConsumerTest extends BaseConsum

[GitHub] [kafka] dajac commented on pull request #11688: KAFKA-13435; Static membership protocol should let the leader skip assignment (KIP-814)

dajac commented on pull request #11688: URL: https://github.com/apache/kafka/pull/11688#issuecomment-1033635997 @hachikuji @showuon Thanks for reviewing. I have updated the PR based on your comments. I have also bumped to version of the JoinGroup API to v9. I thought that we could lean on

[GitHub] [kafka] FireBurn commented on pull request #11685: Update dependencies.gradle

FireBurn commented on pull request #11685: URL: https://github.com/apache/kafka/pull/11685#issuecomment-1033636049 Can we replace with reload4j https://reload4j.qos.ch/ it fixes the bugs of log4j1, is written by the same developer and doesn't have api changes like log4j2 -- This

[jira] [Resolved] (KAFKA-13616) Log4j 1.X CVE-2022-23302/5/7 vulnerabilities

[ https://issues.apache.org/jira/browse/KAFKA-13616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dongjin Lee resolved KAFKA-13616. - Resolution: Duplicate > Log4j 1.X CVE-2022-23302/5/7 vulnerabilities > -

[GitHub] [kafka] tombentley commented on a change in pull request #11672: KAFKA-13577: Replace easymock with mockito in kafka:core - part 1

tombentley commented on a change in pull request #11672: URL: https://github.com/apache/kafka/pull/11672#discussion_r802574591 ## File path: core/src/test/scala/kafka/common/InterBrokerSendThreadTest.scala ## @@ -134,36 +139,45 @@ class InterBrokerSendThreadTest { val cl

[jira] [Created] (KAFKA-13659) MM2 should read all offset syncs at start up and should not set consumer offset higher than the end offset

Kanalas Vidor created KAFKA-13659: - Summary: MM2 should read all offset syncs at start up and should not set consumer offset higher than the end offset Key: KAFKA-13659 URL: https://issues.apache.org/jira/browse/K

[GitHub] [kafka] FireBurn opened a new pull request #11743: Switch log4j12 to reload4j

FireBurn opened a new pull request #11743: URL: https://github.com/apache/kafka/pull/11743 This bumps the slf4j version to 1.7.36 and swaps out log4j 1.2.17 with reload4j 1.2.19 Signed-off-by: Mike Lothian *More detailed description of your change, if necessary. The PR t

[GitHub] [kafka] FireBurn commented on pull request #11685: Update dependencies.gradle

FireBurn commented on pull request #11685: URL: https://github.com/apache/kafka/pull/11685#issuecomment-1033694596 I've raised https://github.com/apache/kafka/pull/11743 to switch to reload4j -- This is an automated message from the Apache Git Service. To respond to the message, please lo

[GitHub] [kafka] showuon commented on a change in pull request #11688: KAFKA-13435; Static membership protocol should let the leader skip assignment (KIP-814)

showuon commented on a change in pull request #11688: URL: https://github.com/apache/kafka/pull/11688#discussion_r802624600 ## File path: core/src/test/scala/integration/kafka/api/PlaintextConsumerTest.scala ## @@ -1791,4 +1793,33 @@ class PlaintextConsumerTest extends BaseCons

[GitHub] [kafka] lmr3796 opened a new pull request #11744: MINOR: Fix JavaDoc of OffsetIndex#append

lmr3796 opened a new pull request #11744: URL: https://github.com/apache/kafka/pull/11744 The Java doc for the thrown exception is added in (apache#4975) https://github.com/apache/kafka/pull/4975/files#diff-f3714fa2bb7e07c857d2cafde9dcb5d310fafd2cceed9f4124cc6342671a2c89R137 By th

[GitHub] [kafka] lmr3796 commented on pull request #11744: MINOR: Fix JavaDoc of OffsetIndex#append

lmr3796 commented on pull request #11744: URL: https://github.com/apache/kafka/pull/11744#issuecomment-1033729356 Hi @chia7712 can I get a review from you for this minor patch? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [kafka] ijuma commented on pull request #9972: KAFKA-8779: Reintroduce flaky tests

ijuma commented on pull request #9972: URL: https://github.com/apache/kafka/pull/9972#issuecomment-1033748707 @chia7712 Does this look good to you? -- 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 t

[GitHub] [kafka] showuon commented on a change in pull request #11688: KAFKA-13435; Static membership protocol should let the leader skip assignment (KIP-814)

showuon commented on a change in pull request #11688: URL: https://github.com/apache/kafka/pull/11688#discussion_r802633329 ## File path: clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java ## @@ -648,10 +648,14 @@ private void maybeUpdat

[GitHub] [kafka] mimaison closed pull request #4934: KIP-81: KAFKA-4133: Bound memory usage of the Consumer

mimaison closed pull request #4934: URL: https://github.com/apache/kafka/pull/4934 -- 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] mimaison closed pull request #6193: [WIP] KIP-81 Bound Fetch memory usage in the consumer

mimaison closed pull request #6193: URL: https://github.com/apache/kafka/pull/6193 -- 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 a change in pull request #11688: KAFKA-13435; Static membership protocol should let the leader skip assignment (KIP-814)

dajac commented on a change in pull request #11688: URL: https://github.com/apache/kafka/pull/11688#discussion_r802733093 ## File path: clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java ## @@ -648,10 +648,14 @@ private void maybeUpdateG

[GitHub] [kafka] tombentley commented on a change in pull request #11642: MINOR: Improve Connect docs

tombentley commented on a change in pull request #11642: URL: https://github.com/apache/kafka/pull/11642#discussion_r802748846 ## File path: connect/runtime/src/main/java/org/apache/kafka/connect/tools/PredicateDoc.java ## @@ -61,7 +61,7 @@ private static void printPredicateHt

[GitHub] [kafka] dengziming commented on a change in pull request #11667: MINOR; Enable Kraft in ApiVersionTest

dengziming commented on a change in pull request #11667: URL: https://github.com/apache/kafka/pull/11667#discussion_r802758354 ## File path: core/src/test/scala/unit/kafka/server/AbstractApiVersionsRequestTest.scala ## @@ -34,18 +36,25 @@ import scala.jdk.CollectionConverters.

[GitHub] [kafka] dengziming commented on a change in pull request #11667: MINOR; Enable Kraft in ApiVersionTest

dengziming commented on a change in pull request #11667: URL: https://github.com/apache/kafka/pull/11667#discussion_r802760455 ## File path: core/src/test/scala/unit/kafka/server/AbstractApiVersionsRequestTest.scala ## @@ -59,15 +68,40 @@ abstract class AbstractApiVersionsRequ

[jira] [Assigned] (KAFKA-13659) MM2 should read all offset syncs at start up and should not set consumer offset higher than the end offset

[ https://issues.apache.org/jira/browse/KAFKA-13659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Viktor Somogyi-Vass reassigned KAFKA-13659: --- Assignee: Kanalas Vidor > MM2 should read all offset syncs at start up and

[jira] [Commented] (KAFKA-12635) Mirrormaker 2 offset sync is incorrect if the target partition is empty

[ https://issues.apache.org/jira/browse/KAFKA-12635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489631#comment-17489631 ] Mickael Maison commented on KAFKA-12635: Looking at this again (sorry for the de

[jira] [Commented] (KAFKA-13659) MM2 should read all offset syncs at start up and should not set consumer offset higher than the end offset

[ https://issues.apache.org/jira/browse/KAFKA-13659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489633#comment-17489633 ] Mickael Maison commented on KAFKA-13659: Is this a DUP of https://issues.apache.

[jira] [Commented] (KAFKA-13638) Slow KTable update when forwarding multiple values from transformer

[ https://issues.apache.org/jira/browse/KAFKA-13638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489636#comment-17489636 ] Ulrik commented on KAFKA-13638: --- [~cadonna]  Very strange. I added the same code as you an

[GitHub] [kafka] dajac commented on a change in pull request #11742: KAFKA-13636: Fix for the group coordinator issue where the offsets are deleted for unstable groups

dajac commented on a change in pull request #11742: URL: https://github.com/apache/kafka/pull/11742#discussion_r802805279 ## File path: core/src/test/scala/unit/kafka/coordinator/group/GroupMetadataTest.scala ## @@ -259,6 +259,47 @@ class GroupMetadataTest { assertFalse(g

[GitHub] [kafka] mimaison commented on a change in pull request #11167: Kafka-13158 Replace EasyMock and PowerMock with Mockito for ConnectClusterStateImpl Test and ConnectorPluginsResourceTest

mimaison commented on a change in pull request #11167: URL: https://github.com/apache/kafka/pull/11167#discussion_r802807309 ## File path: build.gradle ## @@ -2373,7 +2373,7 @@ project(':connect:runtime') { testImplementation libs.junitVintageEngine testImplementation

[GitHub] [kafka] mimaison merged pull request #11672: KAFKA-13577: Replace easymock with mockito in kafka:core - part 1

mimaison merged pull request #11672: URL: https://github.com/apache/kafka/pull/11672 -- 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-13660) Replace log4j with reload4j

Mike Lothian created KAFKA-13660: Summary: Replace log4j with reload4j Key: KAFKA-13660 URL: https://issues.apache.org/jira/browse/KAFKA-13660 Project: Kafka Issue Type: Bug Compone

[jira] [Updated] (KAFKA-13660) Replace log4j with reload4j

[ https://issues.apache.org/jira/browse/KAFKA-13660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mike Lothian updated KAFKA-13660: - Description: Kafka is using a known vulnerable version of log4j, the reload4j project was creat

[GitHub] [kafka] mimaison commented on a change in pull request #11642: MINOR: Improve Connect docs

mimaison commented on a change in pull request #11642: URL: https://github.com/apache/kafka/pull/11642#discussion_r802920885 ## File path: docs/connect.html ## @@ -414,53 +403,49 @@ Connector We'll cover the SourceConnector as a simple example. SinkConnector implementatio

[GitHub] [kafka] mimaison commented on a change in pull request #11642: MINOR: Improve Connect docs

mimaison commented on a change in pull request #11642: URL: https://github.com/apache/kafka/pull/11642#discussion_r802932268 ## File path: connect/runtime/src/main/java/org/apache/kafka/connect/tools/PredicateDoc.java ## @@ -61,7 +61,7 @@ private static void printPredicateHtml

[GitHub] [kafka] mimaison commented on a change in pull request #11642: MINOR: Improve Connect docs

mimaison commented on a change in pull request #11642: URL: https://github.com/apache/kafka/pull/11642#discussion_r802932268 ## File path: connect/runtime/src/main/java/org/apache/kafka/connect/tools/PredicateDoc.java ## @@ -61,7 +61,7 @@ private static void printPredicateHtml

[GitHub] [kafka] hachikuji commented on a change in pull request #11655: KAFKA-13316; Enable KRaft mode in CreateTopics tests

hachikuji commented on a change in pull request #11655: URL: https://github.com/apache/kafka/pull/11655#discussion_r802933225 ## File path: core/src/test/scala/unit/kafka/server/CreateTopicsRequestWithPolicyTest.scala ## @@ -55,11 +63,9 @@ class CreateTopicsRequestWithPolicyTe

[jira] [Commented] (KAFKA-13159) Enable system tests for transactions in KRaft mode

[ https://issues.apache.org/jira/browse/KAFKA-13159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489704#comment-17489704 ] Mickael Maison commented on KAFKA-13159: [~mumrah] I see https://github.com/apac

[jira] [Updated] (KAFKA-12622) Automate LICENSE file validation

[ https://issues.apache.org/jira/browse/KAFKA-12622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison updated KAFKA-12622: --- Fix Version/s: (was: 3.0.1) > Automate LICENSE file validation > ---

[jira] [Commented] (KAFKA-13142) KRaft brokers do not validate dynamic configs before forwarding them to controller

[ https://issues.apache.org/jira/browse/KAFKA-13142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489710#comment-17489710 ] Mickael Maison commented on KAFKA-13142: [~rdielhenn] Is this really a blocker?

[jira] [Updated] (KAFKA-12644) Add Missing Class-Level Javadoc to Descendants of org.apache.kafka.common.errors.ApiException

[ https://issues.apache.org/jira/browse/KAFKA-12644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison updated KAFKA-12644: --- Fix Version/s: (was: 3.0.1) > Add Missing Class-Level Javadoc to Descendants of > org.a

[jira] [Updated] (KAFKA-12774) kafka-streams 2.8: logging in uncaught-exceptionhandler doesn't go through log4j

[ https://issues.apache.org/jira/browse/KAFKA-12774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison updated KAFKA-12774: --- Fix Version/s: (was: 3.0.1) > kafka-streams 2.8: logging in uncaught-exceptionhandler do

[jira] [Updated] (KAFKA-13411) Exception while connecting from kafka client consumer producers deployed in a wildfly context to a kafka broker implementing OAUTHBEARER sasl mechanism

[ https://issues.apache.org/jira/browse/KAFKA-13411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison updated KAFKA-13411: --- Fix Version/s: (was: 3.0.1) > Exception while connecting from kafka client consumer prod

[jira] [Updated] (KAFKA-13228) ApiVersionRequest are not correctly handled in kraft mode

[ https://issues.apache.org/jira/browse/KAFKA-13228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison updated KAFKA-13228: --- Fix Version/s: (was: 3.0.1) > ApiVersionRequest are not correctly handled in kraft mode

[jira] [Updated] (KAFKA-13188) Release the memory back into MemoryPool

[ https://issues.apache.org/jira/browse/KAFKA-13188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison updated KAFKA-13188: --- Fix Version/s: (was: 3.0.1) > Release the memory back into MemoryPool >

[jira] [Updated] (KAFKA-13242) KRaft Controller doesn't handle UpdateFeaturesRequest

[ https://issues.apache.org/jira/browse/KAFKA-13242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison updated KAFKA-13242: --- Fix Version/s: (was: 3.0.1) > KRaft Controller doesn't handle UpdateFeaturesRequest > --

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

[ https://issues.apache.org/jira/browse/KAFKA-13517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison updated KAFKA-13517: --- Fix Version/s: (was: 2.8.1) > Add ConfigurationKeys to ConfigResource class > --

[jira] [Commented] (KAFKA-12468) Initial offsets are copied from source to target cluster

[ https://issues.apache.org/jira/browse/KAFKA-12468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489716#comment-17489716 ] Guram Savinov commented on KAFKA-12468: --- [~bdeneuter] there is IdentityReplication

[jira] [Updated] (KAFKA-13661) KRaft uses the wrong permission for adding topic partitions

[ https://issues.apache.org/jira/browse/KAFKA-13661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-13661: Summary: KRaft uses the wrong permission for adding topic partitions (was: KRaft uses the

[jira] [Created] (KAFKA-13661) KRaft uses the wrong permission for creating partitions

Jason Gustafson created KAFKA-13661: --- Summary: KRaft uses the wrong permission for creating partitions Key: KAFKA-13661 URL: https://issues.apache.org/jira/browse/KAFKA-13661 Project: Kafka

[jira] [Commented] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489723#comment-17489723 ] Guram Savinov commented on KAFKA-7500: -- Please update KIP-382 documentation: Legacy

[GitHub] [kafka] tombentley commented on a change in pull request #11673: KAFKA-13577: Replace easymock with mockito in kafka:core - part 2

tombentley commented on a change in pull request #11673: URL: https://github.com/apache/kafka/pull/11673#discussion_r802922650 ## File path: core/src/test/scala/unit/kafka/server/ReplicaManagerQuotasTest.scala ## @@ -157,10 +158,9 @@ class ReplicaManagerQuotasTest { def shou

[GitHub] [kafka] hachikuji merged pull request #11649: KAFKA-13646: Implement KIP-801: KRaft authorizer

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

[jira] [Resolved] (KAFKA-13646) Implement KIP-801: KRaft authorizer

[ https://issues.apache.org/jira/browse/KAFKA-13646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-13646. - Fix Version/s: 3.2.0 Resolution: Fixed > Implement KIP-801: KRaft authorizer > --

[jira] [Commented] (KAFKA-13638) Slow KTable update when forwarding multiple values from transformer

[ https://issues.apache.org/jira/browse/KAFKA-13638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489741#comment-17489741 ] Bruno Cadonna commented on KAFKA-13638: --- [~Lejon] Could you try to use another sta

[jira] [Commented] (KAFKA-13422) Even if the correct username and password are configured, when ClientBroker or KafkaClient tries to establish a SASL connection to ServerBroker, an exception is thrown

[ https://issues.apache.org/jira/browse/KAFKA-13422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489744#comment-17489744 ] Guozhang Wang commented on KAFKA-13422: --- I'm unfortunately less familiar with secu

[GitHub] [kafka] mimaison commented on a change in pull request #11673: KAFKA-13577: Replace easymock with mockito in kafka:core - part 2

mimaison commented on a change in pull request #11673: URL: https://github.com/apache/kafka/pull/11673#discussion_r802994307 ## File path: core/src/test/scala/unit/kafka/server/ReplicaManagerQuotasTest.scala ## @@ -157,10 +158,9 @@ class ReplicaManagerQuotasTest { def should

[GitHub] [kafka] mimaison commented on a change in pull request #11744: MINOR: Fix JavaDoc of OffsetIndex#append

mimaison commented on a change in pull request #11744: URL: https://github.com/apache/kafka/pull/11744#discussion_r803007182 ## File path: core/src/main/scala/kafka/log/OffsetIndex.scala ## @@ -136,7 +136,7 @@ class OffsetIndex(_file: File, baseOffset: Long, maxIndexSize: Int

[GitHub] [kafka] mimaison commented on pull request #11731: KAFKA-13293: Reloading SSL Engine Factory

mimaison commented on pull request #11731: URL: https://github.com/apache/kafka/pull/11731#issuecomment-1034113905 Thanks @teabot for the contribution! This PR adds new configurations and these are considered public API. So in order to accept this change we need a [Kafka Improvement

[GitHub] [kafka] lmr3796 closed pull request #11744: MINOR: Fix JavaDoc of OffsetIndex#append

lmr3796 closed pull request #11744: URL: https://github.com/apache/kafka/pull/11744 -- 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] vvcephei closed pull request #1468: KAFKA-3790: Allow for removal of non specific ACLs

vvcephei closed pull request #1468: URL: https://github.com/apache/kafka/pull/1468 -- 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] vvcephei commented on pull request #1468: KAFKA-3790: Allow for removal of non specific ACLs

vvcephei commented on pull request #1468: URL: https://github.com/apache/kafka/pull/1468#issuecomment-1034117452 Hi @slaunay , It seems like this PR stalled. I'll close it out for now, but if you or anyone else want to resume this work, please feel free to re-open it (or start a new

[GitHub] [kafka] vvcephei commented on pull request #1415: KAFKA-3737: Change log level for error during produce request

vvcephei commented on pull request #1415: URL: https://github.com/apache/kafka/pull/1415#issuecomment-1034117748 Hi @fhussonnois , It seems like this PR stalled. I'll close it out for now, but if you or anyone else want to resume this work, please feel free to re-open it (or start a

[GitHub] [kafka] vvcephei closed pull request #1415: KAFKA-3737: Change log level for error during produce request

vvcephei closed pull request #1415: URL: https://github.com/apache/kafka/pull/1415 -- 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] vvcephei closed pull request #1269: KAFKA-3622: Use descriptive error message if port number is missing from url

vvcephei closed pull request #1269: URL: https://github.com/apache/kafka/pull/1269 -- 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] vvcephei commented on pull request #1269: KAFKA-3622: Use descriptive error message if port number is missing from url

vvcephei commented on pull request #1269: URL: https://github.com/apache/kafka/pull/1269#issuecomment-1034118007 Hi @peterableda , It seems like this PR stalled. I'll close it out for now, but if you or anyone else want to resume this work, please feel free to re-open it (or start a

[GitHub] [kafka] vvcephei commented on pull request #1244: MINOR: Docs for ACLs over SSL auth and KAFKA_OPTS

vvcephei commented on pull request #1244: URL: https://github.com/apache/kafka/pull/1244#issuecomment-1034118238 Hi @QwertyManiac , It seems like this PR stalled. I'll close it out for now, but if you or anyone else want to resume this work, please feel free to re-open it (or start

[GitHub] [kafka] vvcephei closed pull request #1244: MINOR: Docs for ACLs over SSL auth and KAFKA_OPTS

vvcephei closed pull request #1244: URL: https://github.com/apache/kafka/pull/1244 -- 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] vvcephei closed pull request #1150: KAFKA-3474: add metrics to track replica fetcher timeouts

vvcephei closed pull request #1150: URL: https://github.com/apache/kafka/pull/1150 -- 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] vvcephei commented on pull request #1150: KAFKA-3474: add metrics to track replica fetcher timeouts

vvcephei commented on pull request #1150: URL: https://github.com/apache/kafka/pull/1150#issuecomment-1034118461 Hi @junrao , It seems like this PR stalled. I'll close it out for now, but if you or anyone else want to resume this work, please feel free to re-open it (or start a new

[GitHub] [kafka] lmr3796 commented on a change in pull request #11744: MINOR: Fix JavaDoc of OffsetIndex#append

lmr3796 commented on a change in pull request #11744: URL: https://github.com/apache/kafka/pull/11744#discussion_r803018010 ## File path: core/src/main/scala/kafka/log/OffsetIndex.scala ## @@ -136,7 +136,7 @@ class OffsetIndex(_file: File, baseOffset: Long, maxIndexSize: Int =

[GitHub] [kafka] vvcephei closed pull request #1147: [KAFKA-3472] Allow MirrorMaker to copy selected partitions and choose target topic name

vvcephei closed pull request #1147: URL: https://github.com/apache/kafka/pull/1147 -- 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] vvcephei commented on pull request #1135: [KAFKA-3458] Selector should throw InterruptException when interrupted.

vvcephei commented on pull request #1135: URL: https://github.com/apache/kafka/pull/1135#issuecomment-1034118967 Hi @sruehl , It seems like this PR stalled. I'll close it out for now, but if you or anyone else want to resume this work, please feel free to re-open it (or start a new

[GitHub] [kafka] vvcephei closed pull request #1111: KAFKA-3428 Remove metadata sync bottleneck from mirrormaker's producer

vvcephei closed pull request #: URL: https://github.com/apache/kafka/pull/ -- 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] vvcephei commented on pull request #1147: [KAFKA-3472] Allow MirrorMaker to copy selected partitions and choose target topic name

vvcephei commented on pull request #1147: URL: https://github.com/apache/kafka/pull/1147#issuecomment-1034118707 Hi @ooasis , It seems like this PR stalled. I'll close it out for now, but if you or anyone else want to resume this work, please feel free to re-open it (or start a new

[GitHub] [kafka] vvcephei closed pull request #1135: [KAFKA-3458] Selector should throw InterruptException when interrupted.

vvcephei closed pull request #1135: URL: https://github.com/apache/kafka/pull/1135 -- 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] vvcephei commented on pull request #1111: KAFKA-3428 Remove metadata sync bottleneck from mirrormaker's producer

vvcephei commented on pull request #: URL: https://github.com/apache/kafka/pull/#issuecomment-1034119203 Hi @maysamyabandeh , It seems like this PR stalled. I'll close it out for now, but if you or anyone else want to resume this work, please feel free to re-open it (or start

[GitHub] [kafka] vvcephei closed pull request #1078: Fixes for Windows #154

vvcephei closed pull request #1078: URL: https://github.com/apache/kafka/pull/1078 -- 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] vvcephei commented on pull request #1078: Fixes for Windows #154

vvcephei commented on pull request #1078: URL: https://github.com/apache/kafka/pull/1078#issuecomment-1034119371 Hi @JeffersJi , It seems like this PR stalled. I'll close it out for now, but if you or anyone else want to resume this work, please feel free to re-open it (or start a n

[GitHub] [kafka] vvcephei commented on pull request #1035: KAFKA-3359 Parallel log-recovery of un-flushed segments on startup

vvcephei commented on pull request #1035: URL: https://github.com/apache/kafka/pull/1035#issuecomment-1034119827 Hello, It seems like this PR stalled. I'll close it out for now, but if you or anyone else want to resume this work, please feel free to re-open it (or start a new one)!

[GitHub] [kafka] vvcephei commented on pull request #983: KAFKA-3300: Avoid over allocating disk space and memory for index files.

vvcephei commented on pull request #983: URL: https://github.com/apache/kafka/pull/983#issuecomment-1034120088 Hi @becketqin , It seems like this PR stalled. I'll close it out for now, but if you or anyone else want to resume this work, please feel free to re-open it (or start a new

[GitHub] [kafka] vvcephei closed pull request #983: KAFKA-3300: Avoid over allocating disk space and memory for index files.

vvcephei closed pull request #983: URL: https://github.com/apache/kafka/pull/983 -- 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] vvcephei closed pull request #1035: KAFKA-3359 Parallel log-recovery of un-flushed segments on startup

vvcephei closed pull request #1035: URL: https://github.com/apache/kafka/pull/1035 -- 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] vvcephei commented on pull request #907: KAFKA-3234; Clarify minISR in documentation and auto-generate topic configuration docs

vvcephei commented on pull request #907: URL: https://github.com/apache/kafka/pull/907#issuecomment-1034120532 Hi @jjkoshy , It seems like this PR stalled. I'll close it out for now, but if you or anyone else want to resume this work, please feel free to re-open it (or start a new o

[GitHub] [kafka] vvcephei closed pull request #907: KAFKA-3234; Clarify minISR in documentation and auto-generate topic configuration docs

vvcephei closed pull request #907: URL: https://github.com/apache/kafka/pull/907 -- 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] vvcephei closed pull request #880: KAFKA-3190 Producer should not fire callback in Send() method

vvcephei closed pull request #880: URL: https://github.com/apache/kafka/pull/880 -- 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] vvcephei commented on pull request #880: KAFKA-3190 Producer should not fire callback in Send() method

vvcephei commented on pull request #880: URL: https://github.com/apache/kafka/pull/880#issuecomment-1034120832 Hi @becketqin , It seems like this PR stalled. I'll close it out for now, but if you or anyone else want to resume this work, please feel free to re-open it (or start a new

[GitHub] [kafka] vvcephei closed pull request #824: KAFKA-3161: Fixed ProducerConfig/ConsumerConfig so that defaults are used in java.util.Properties

vvcephei closed pull request #824: URL: https://github.com/apache/kafka/pull/824 -- 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] vvcephei commented on pull request #824: KAFKA-3161: Fixed ProducerConfig/ConsumerConfig so that defaults are used in java.util.Properties

vvcephei commented on pull request #824: URL: https://github.com/apache/kafka/pull/824#issuecomment-1034121012 Hi @crhyne , It seems like this PR stalled. I'll close it out for now, but if you or anyone else want to resume this work, please feel free to re-open it (or start a new on

[GitHub] [kafka] vvcephei commented on pull request #757: KAFKA-3082: Make LogManager.InitialTaskDelayMs configurable

vvcephei commented on pull request #757: URL: https://github.com/apache/kafka/pull/757#issuecomment-1034121306 Ho @j-nowak , It seems like this PR stalled. I'll close it out for now, but if you or anyone else want to resume this work, please feel free to re-open it (or start a new o

[GitHub] [kafka] vvcephei closed pull request #757: KAFKA-3082: Make LogManager.InitialTaskDelayMs configurable

vvcephei closed pull request #757: URL: https://github.com/apache/kafka/pull/757 -- 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] vvcephei closed pull request #735: KAFKA-3065: Remove unused topic partitions from RecordAccumulator

vvcephei closed pull request #735: URL: https://github.com/apache/kafka/pull/735 -- 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] vvcephei commented on pull request #735: KAFKA-3065: Remove unused topic partitions from RecordAccumulator

vvcephei commented on pull request #735: URL: https://github.com/apache/kafka/pull/735#issuecomment-1034121499 Hi @rajinisivaram , It seems like this PR stalled. I'll close it out for now, but if you or anyone else want to resume this work, please feel free to re-open it (or start a

[GitHub] [kafka] vvcephei commented on pull request #719: KAFKA-3049: VerifiableProperties does not respect 'default' properties of underlying java.util.Properties instance

vvcephei commented on pull request #719: URL: https://github.com/apache/kafka/pull/719#issuecomment-1034121675 Hi @jeffreyolchovy , It seems like this PR stalled. I'll close it out for now, but if you or anyone else want to resume this work, please feel free to re-open it (or start

[GitHub] [kafka] vvcephei closed pull request #719: KAFKA-3049: VerifiableProperties does not respect 'default' properties of underlying java.util.Properties instance

vvcephei closed pull request #719: URL: https://github.com/apache/kafka/pull/719 -- 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] vvcephei commented on pull request #62: add support libvirt as provider. KAFKA-2183

vvcephei commented on pull request #62: URL: https://github.com/apache/kafka/pull/62#issuecomment-1034121935 Hi @pronix , It seems like this PR stalled. I'll close it out for now, but if you or anyone else want to resume this work, please feel free to re-open it (or start a new one)

[GitHub] [kafka] vvcephei closed pull request #62: add support libvirt as provider. KAFKA-2183

vvcephei closed pull request #62: URL: https://github.com/apache/kafka/pull/62 -- 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...@ka

[GitHub] [kafka] vvcephei commented on pull request #200: KAFKA-2512: Add version check to broker and clients.

vvcephei commented on pull request #200: URL: https://github.com/apache/kafka/pull/200#issuecomment-1034122122 Hi @becketqin , It seems like this PR stalled. I'll close it out for now, but if you or anyone else want to resume this work, please feel free to re-open it (or start a new

  1   2   >