[jira] [Commented] (KAFKA-13148) Kraft Controller doesn't handle scheduleAppend returning Long.MAX_VALUE

[ https://issues.apache.org/jira/browse/KAFKA-13148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17389282#comment-17389282 ] dengziming commented on KAFKA-13148: KAFKA-12158 will change the return value of `sc

[GitHub] [kafka] dengziming commented on a change in pull request #10909: KAFKA-12158: Better return type of RaftClient.scheduleAppend

dengziming commented on a change in pull request #10909: URL: https://github.com/apache/kafka/pull/10909#discussion_r678851319 ## File path: raft/src/main/java/org/apache/kafka/raft/RaftAppendResult.java ## @@ -0,0 +1,83 @@ +/* + * Licensed to the Apache Software Foundation (AS

[jira] [Comment Edited] (KAFKA-9858) CVE-2016-3189 Use-after-free vulnerability in bzip2recover in bzip2 1.0.6 allows remote attackers to cause a denial of service (crash) via a crafted bzip2 file, r

[ https://issues.apache.org/jira/browse/KAFKA-9858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17389272#comment-17389272 ] eastcowboy edited comment on KAFKA-9858 at 7/29/21, 5:40 AM: -

[jira] [Comment Edited] (KAFKA-9858) CVE-2016-3189 Use-after-free vulnerability in bzip2recover in bzip2 1.0.6 allows remote attackers to cause a denial of service (crash) via a crafted bzip2 file, r

[ https://issues.apache.org/jira/browse/KAFKA-9858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17389272#comment-17389272 ] eastcowboy edited comment on KAFKA-9858 at 7/29/21, 5:39 AM: -

[jira] [Commented] (KAFKA-9858) CVE-2016-3189 Use-after-free vulnerability in bzip2recover in bzip2 1.0.6 allows remote attackers to cause a denial of service (crash) via a crafted bzip2 file, relate

[ https://issues.apache.org/jira/browse/KAFKA-9858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17389272#comment-17389272 ] eastcowboy commented on KAFKA-9858: --- [~guozhang] rocksdbjni has already fixed this iss

[jira] [Updated] (KAFKA-13149) Null Pointer Exception when record==null when handling a produce request

[ https://issues.apache.org/jira/browse/KAFKA-13149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Cong Ding updated KAFKA-13149: -- Summary: Null Pointer Exception when record==null when handling a produce request (was: Null Pointer

[jira] [Updated] (KAFKA-13149) Null Pointer Exception for record==null when handling a produce request

[ https://issues.apache.org/jira/browse/KAFKA-13149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Cong Ding updated KAFKA-13149: -- Summary: Null Pointer Exception for record==null when handling a produce request (was: Null Pointer E

[jira] [Updated] (KAFKA-13149) Null Pointer Exception if record==null when handling a produce request

[ https://issues.apache.org/jira/browse/KAFKA-13149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Cong Ding updated KAFKA-13149: -- Summary: Null Pointer Exception if record==null when handling a produce request (was: Null Pointer Ex

[jira] [Updated] (KAFKA-13149) Null Pointer Exception when record==null at produce path

[ https://issues.apache.org/jira/browse/KAFKA-13149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Cong Ding updated KAFKA-13149: -- Description: In production, we have seen an exception {code:java} java.lang.NullPointerException: Cann

[jira] [Updated] (KAFKA-13149) Null Pointer Exception when record==null at produce path

[ https://issues.apache.org/jira/browse/KAFKA-13149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Cong Ding updated KAFKA-13149: -- Description: In production, we have seen an exception {code:java} java.lang.NullPointerException: Cann

[jira] [Updated] (KAFKA-13149) Null Pointer Exception when record==null at produce path

[ https://issues.apache.org/jira/browse/KAFKA-13149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Cong Ding updated KAFKA-13149: -- Priority: Major (was: Blocker) > Null Pointer Exception when record==null at produce path > -

[jira] [Created] (KAFKA-13149) Null Pointer Exception when record==null at produce path

Cong Ding created KAFKA-13149: - Summary: Null Pointer Exception when record==null at produce path Key: KAFKA-13149 URL: https://issues.apache.org/jira/browse/KAFKA-13149 Project: Kafka Issue Type

[GitHub] [kafka] showuon commented on a change in pull request #11120: Add support for infinite endpoints for range queries

showuon commented on a change in pull request #11120: URL: https://github.com/apache/kafka/pull/11120#discussion_r678776434 ## File path: streams/src/test/java/org/apache/kafka/streams/state/internals/AbstractKeyValueStoreTest.java ## @@ -383,13 +394,29 @@ public void shouldTh

[GitHub] [kafka] showuon commented on a change in pull request #11120: Add support for infinite endpoints for range queries

showuon commented on a change in pull request #11120: URL: https://github.com/apache/kafka/pull/11120#discussion_r678771300 ## File path: streams/src/main/java/org/apache/kafka/streams/state/ReadOnlyKeyValueStore.java ## @@ -65,9 +66,10 @@ * Order is not guaranteed as by

[GitHub] [kafka] showuon commented on a change in pull request #11120: Add support for infinite endpoints for range queries

showuon commented on a change in pull request #11120: URL: https://github.com/apache/kafka/pull/11120#discussion_r678771300 ## File path: streams/src/main/java/org/apache/kafka/streams/state/ReadOnlyKeyValueStore.java ## @@ -65,9 +66,10 @@ * Order is not guaranteed as by

[GitHub] [kafka] ableegoldman commented on pull request #10881: KAFKA-12947 Replace EasyMock and PowerMock with Mockito for Streams…

ableegoldman commented on pull request #10881: URL: https://github.com/apache/kafka/pull/10881#issuecomment-888743634 I think this looks good but there's a merge conflict, can you fix that? -- This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [kafka] vvcephei merged pull request #11099: KAFKA-10542: Migrate KTable mapValues, passthrough, and source to new Processor API

vvcephei merged pull request #11099: URL: https://github.com/apache/kafka/pull/11099 -- 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 a change in pull request #11099: KAFKA-10542: Migrate KTable mapValues, passthrough, and source to new Processor API

vvcephei commented on a change in pull request #11099: URL: https://github.com/apache/kafka/pull/11099#discussion_r67871 ## File path: streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableSource.java ## @@ -92,33 +98,62 @@ public void init(final org.apac

[GitHub] [kafka] vvcephei commented on a change in pull request #11099: KAFKA-10542: Migrate KTable mapValues, passthrough, and source to new Processor API

vvcephei commented on a change in pull request #11099: URL: https://github.com/apache/kafka/pull/11099#discussion_r678766017 ## File path: streams/src/test/java/org/apache/kafka/streams/processor/internals/GlobalStreamThreadTest.java ## @@ -90,6 +92,13 @@ public String newStor

[GitHub] [kafka] rondagostino commented on pull request #11131: KAFKA-13137: KRaft Controller Metric MBean names incorrectly quoted

rondagostino commented on pull request #11131: URL: https://github.com/apache/kafka/pull/11131#issuecomment-888721165 Thanks, @hachikuji -- I think it's good now. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the UR

[GitHub] [kafka] lbradstreet commented on a change in pull request #11140: MINOR: log epoch and offset truncation similarly to HWM truncation

lbradstreet commented on a change in pull request #11140: URL: https://github.com/apache/kafka/pull/11140#discussion_r678720053 ## File path: core/src/main/scala/kafka/server/AbstractFetcherThread.scala ## @@ -265,6 +265,7 @@ abstract class AbstractFetcherThread(name: String,

[GitHub] [kafka] hachikuji commented on a change in pull request #11131: KAFKA-13137: KRaft Controller Metric MBean names incorrectly quoted

hachikuji commented on a change in pull request #11131: URL: https://github.com/apache/kafka/pull/11131#discussion_r678716922 ## File path: metadata/src/main/java/org/apache/kafka/controller/ControllerMetrics.java ## @@ -42,4 +42,6 @@ void setPreferredReplicaImbalanceCoun

[GitHub] [kafka] dielhennr commented on a change in pull request #11133: KAFKA-13140: KRaft brokers do not expose kafka.controller metrics

dielhennr commented on a change in pull request #11133: URL: https://github.com/apache/kafka/pull/11133#discussion_r678717206 ## File path: core/src/main/scala/kafka/server/KafkaRaftServer.scala ## @@ -100,6 +101,9 @@ class KafkaRaftServer( controllerQuorumVotersFuture

[GitHub] [kafka] hachikuji commented on a change in pull request #11140: MINOR: log epoch and offset truncation similarly to HWM truncation

hachikuji commented on a change in pull request #11140: URL: https://github.com/apache/kafka/pull/11140#discussion_r678715228 ## File path: core/src/main/scala/kafka/server/AbstractFetcherThread.scala ## @@ -265,6 +265,7 @@ abstract class AbstractFetcherThread(name: String,

[jira] [Assigned] (KAFKA-13091) Increment HW after shrinking ISR through AlterIsr

[ https://issues.apache.org/jira/browse/KAFKA-13091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-13091: --- Assignee: Jason Gustafson (was: David Arthur) > Increment HW after shrinking ISR t

[jira] [Assigned] (KAFKA-13132) Upgrading to topic IDs in LISR requests has gaps introduced in 3.0

[ https://issues.apache.org/jira/browse/KAFKA-13132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jose Armando Garcia Sancio reassigned KAFKA-13132: -- Assignee: Jose Armando Garcia Sancio (was: Justine Olshan) >

[GitHub] [kafka] vvcephei commented on a change in pull request #11120: Add support for infinite endpoints for range queries

vvcephei commented on a change in pull request #11120: URL: https://github.com/apache/kafka/pull/11120#discussion_r678508853 ## File path: streams/src/main/java/org/apache/kafka/streams/state/ReadOnlyKeyValueStore.java ## @@ -65,9 +66,10 @@ * Order is not guaranteed as b

[GitHub] [kafka] hachikuji commented on a change in pull request #11126: KAFKA-13132: Upgrading to topic IDs in LISR requests has gaps introduced in 3.0

hachikuji commented on a change in pull request #11126: URL: https://github.com/apache/kafka/pull/11126#discussion_r678678022 ## File path: core/src/main/scala/kafka/server/ReplicaManager.scala ## @@ -1394,15 +1394,11 @@ class ReplicaManager(val config: KafkaConfig,

[jira] [Resolved] (KAFKA-13141) Leader should not update follower fetch offset if diverging epoch is present

[ https://issues.apache.org/jira/browse/KAFKA-13141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-13141. Reviewer: Jason Gustafson Resolution: Fixed > Leader should not update follower fetc

[GitHub] [kafka] ableegoldman commented on pull request #10897: MINOR: Reduced severity for "skipping records" falling out of time windows

ableegoldman commented on pull request #10897: URL: https://github.com/apache/kafka/pull/10897#issuecomment-888633158 Hey @xdgrulez , this PR has a number of test failures. It looks like there are quite a few tests that are verifying the existence of this specific message, and failing beca

[GitHub] [kafka] niket-goel opened a new pull request #11142: kafka-13148 Renounce leadership of the controller quorum when encountering a failure to append to metadata log.

niket-goel opened a new pull request #11142: URL: https://github.com/apache/kafka/pull/11142 This could happen either because a new leader was elected or because the current leader was unable to allocate memory for the incoming records -- This is an automated message from the Apach

[GitHub] [kafka] hachikuji commented on a change in pull request #10909: KAFKA-12158: Better return type of RaftClient.scheduleAppend

hachikuji commented on a change in pull request #10909: URL: https://github.com/apache/kafka/pull/10909#discussion_r678655283 ## File path: raft/src/main/java/org/apache/kafka/raft/RaftAppendResult.java ## @@ -0,0 +1,83 @@ +/* + * Licensed to the Apache Software Foundation (ASF

[GitHub] [kafka] dielhennr opened a new pull request #11141: KAFKA-13142: Validate config alterations prior to forwarding them to the controller in KRaft.

dielhennr opened a new pull request #11141: URL: https://github.com/apache/kafka/pull/11141 A requirement of KRaft is that it is upgradable from v3.0. However, invalid dynamic configs were previously not being validated before being persisted to the metadata quorum. This means that subsequ

[GitHub] [kafka] jolshan commented on a change in pull request #11126: KAFKA-13132: Upgrading to topic IDs in LISR requests has gaps introduced in 3.0

jolshan commented on a change in pull request #11126: URL: https://github.com/apache/kafka/pull/11126#discussion_r678598522 ## File path: core/src/main/scala/kafka/server/ReplicaManager.scala ## @@ -1405,11 +1393,28 @@ class ReplicaManager(val config: KafkaConfig,

[GitHub] [kafka] jolshan commented on a change in pull request #11126: KAFKA-13132: Upgrading to topic IDs in LISR requests has gaps introduced in 3.0

jolshan commented on a change in pull request #11126: URL: https://github.com/apache/kafka/pull/11126#discussion_r678601444 ## File path: core/src/main/scala/kafka/server/ReplicaManager.scala ## @@ -1405,11 +1393,28 @@ class ReplicaManager(val config: KafkaConfig,

[GitHub] [kafka] jolshan commented on a change in pull request #11126: KAFKA-13132: Upgrading to topic IDs in LISR requests has gaps introduced in 3.0

jolshan commented on a change in pull request #11126: URL: https://github.com/apache/kafka/pull/11126#discussion_r678598522 ## File path: core/src/main/scala/kafka/server/ReplicaManager.scala ## @@ -1405,11 +1393,28 @@ class ReplicaManager(val config: KafkaConfig,

[GitHub] [kafka] jolshan commented on a change in pull request #11126: KAFKA-13132: Upgrading to topic IDs in LISR requests has gaps introduced in 3.0

jolshan commented on a change in pull request #11126: URL: https://github.com/apache/kafka/pull/11126#discussion_r678598522 ## File path: core/src/main/scala/kafka/server/ReplicaManager.scala ## @@ -1405,11 +1393,28 @@ class ReplicaManager(val config: KafkaConfig,

[jira] [Assigned] (KAFKA-13148) Kraft Controller doesn't handle scheduleAppend returning Long.MAX_VALUE

[ https://issues.apache.org/jira/browse/KAFKA-13148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Niket Goel reassigned KAFKA-13148: -- Assignee: Niket Goel > Kraft Controller doesn't handle scheduleAppend returning Long.MAX_VALU

[GitHub] [kafka] hachikuji commented on a change in pull request #11126: KAFKA-13132: Upgrading to topic IDs in LISR requests has gaps introduced in 3.0

hachikuji commented on a change in pull request #11126: URL: https://github.com/apache/kafka/pull/11126#discussion_r678586222 ## File path: core/src/main/scala/kafka/server/ReplicaManager.scala ## @@ -1405,11 +1393,28 @@ class ReplicaManager(val config: KafkaConfig,

[jira] [Commented] (KAFKA-13148) Kraft Controller doesn't handle scheduleAppend returning Long.MAX_VALUE

[ https://issues.apache.org/jira/browse/KAFKA-13148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17388970#comment-17388970 ] Jose Armando Garcia Sancio commented on KAFKA-13148: The controller

[jira] [Created] (KAFKA-13148) Kraft Controller doesn't handle scheduleAppend returning Long.MAX_VALUE

Jose Armando Garcia Sancio created KAFKA-13148: -- Summary: Kraft Controller doesn't handle scheduleAppend returning Long.MAX_VALUE Key: KAFKA-13148 URL: https://issues.apache.org/jira/browse/KAFKA-1314

[GitHub] [kafka] lbradstreet opened a new pull request #11140: MINOR: log epoch and offset truncation similarly to HWM truncation

lbradstreet opened a new pull request #11140: URL: https://github.com/apache/kafka/pull/11140 Example log message: ``` Truncating partition topic1-0 to leader epoch and offset EpochEndOffset(errorCode=0, partition=0, leaderEpoch=3, endOffset=4) ``` -- This is an automated messag

[jira] [Commented] (KAFKA-12957) Refactor Streams Logical Plan Generation

[ https://issues.apache.org/jira/browse/KAFKA-12957?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17388947#comment-17388947 ] Sagar Rao commented on KAFKA-12957: --- hey [~guozhang] i would like to work on this one.

[GitHub] [kafka] guozhangwang merged pull request #11139: MINOR: add helpful error msg

guozhangwang merged pull request #11139: URL: https://github.com/apache/kafka/pull/11139 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: jira-unsu

[jira] [Assigned] (KAFKA-12957) Refactor Streams Logical Plan Generation

[ https://issues.apache.org/jira/browse/KAFKA-12957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sagar Rao reassigned KAFKA-12957: - Assignee: Sagar Rao > Refactor Streams Logical Plan Generation > --

[GitHub] [kafka] wcarlson5 commented on pull request #11139: MINOR: add helpful error msg

wcarlson5 commented on pull request #11139: URL: https://github.com/apache/kafka/pull/11139#issuecomment-888532159 @ableegoldman @guozhangwang @mjsax @cadonna Can I get a quick look at this? -- This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [kafka] wcarlson5 opened a new pull request #11139: MINOR: add helpful error msg

wcarlson5 opened a new pull request #11139: URL: https://github.com/apache/kafka/pull/11139 I noticed that replace thread actions would not be logged unless the user added a log in the handler. I think it would be very useful for debugging ### Committer Checklist (excluded from commi

[jira] [Assigned] (KAFKA-12960) WindowStore and SessionStore do not enforce strict retention time

[ https://issues.apache.org/jira/browse/KAFKA-12960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sagar Rao reassigned KAFKA-12960: - Assignee: Sagar Rao > WindowStore and SessionStore do not enforce strict retention time > -

[jira] [Commented] (KAFKA-12960) WindowStore and SessionStore do not enforce strict retention time

[ https://issues.apache.org/jira/browse/KAFKA-12960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17388946#comment-17388946 ] Sagar Rao commented on KAFKA-12960: --- I would like to take a stab at this one [~mjsax].

[jira] [Updated] (KAFKA-13099) Message too large error when expiring transactionalIds

[ https://issues.apache.org/jira/browse/KAFKA-13099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-13099: Affects Version/s: 2.0.1 2.4.1 2.5.1

[jira] [Updated] (KAFKA-13099) Message too large error when expiring transactionalIds

[ https://issues.apache.org/jira/browse/KAFKA-13099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-13099: Affects Version/s: 2.1.1 2.2.2 2.3.1 > Messa

[jira] [Resolved] (KAFKA-13099) Message too large error when expiring transactionalIds

[ https://issues.apache.org/jira/browse/KAFKA-13099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-13099. - Fix Version/s: 2.8.1 2.7.2 3.0.0 Resolution:

[GitHub] [kafka] ableegoldman commented on pull request #10683: KAFKA-12648: Pt. 2 - Introduce TopologyMetadata to wrap InternalTopologyBuilders of named topologies

ableegoldman commented on pull request #10683: URL: https://github.com/apache/kafka/pull/10683#issuecomment-888521691 Merged to trunk, I'll address the remaining small items in [Pt. 3](https://github.com/apache/kafka/pull/10788) -- thanks @wcarlson5 and @guozhangwang for getting this ove

[GitHub] [kafka] ableegoldman merged pull request #10683: KAFKA-12648: Pt. 2 - Introduce TopologyMetadata to wrap InternalTopologyBuilders of named topologies

ableegoldman merged pull request #10683: URL: https://github.com/apache/kafka/pull/10683 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: jira-unsu

[jira] [Updated] (KAFKA-8295) Add merge() operator to State Stores.

[ https://issues.apache.org/jira/browse/KAFKA-8295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sagar Rao updated KAFKA-8295: - Summary: Add merge() operator to State Stores. (was: Optimize count() using RocksDB merge operator) > A

[jira] [Commented] (KAFKA-8295) Optimize count() using RocksDB merge operator

[ https://issues.apache.org/jira/browse/KAFKA-8295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17388924#comment-17388924 ] Sagar Rao commented on KAFKA-8295: -- I see what you mean and I agree with what you say. I

[GitHub] [kafka] ableegoldman commented on pull request #10683: KAFKA-12648: Pt. 2 - Introduce TopologyMetadata to wrap InternalTopologyBuilders of named topologies

ableegoldman commented on pull request #10683: URL: https://github.com/apache/kafka/pull/10683#issuecomment-888514727 > I only have a concern about keeping track on the topology builders instead on the generated topologies that it may restrict how we want to optimize the topology generatio

[GitHub] [kafka] rondagostino commented on pull request #11131: KAFKA-13137: KRaft Controller Metric MBean names incorrectly quoted

rondagostino commented on pull request #11131: URL: https://github.com/apache/kafka/pull/11131#issuecomment-888509504 @hachikuji I added the deregistration logic; hopefully it looks good and resolves the issue. -- This is an automated message from the Apache Git Service. To respond to th

[GitHub] [kafka] vvcephei commented on a change in pull request #11120: Add support for infinite endpoints for range queries

vvcephei commented on a change in pull request #11120: URL: https://github.com/apache/kafka/pull/11120#discussion_r678508676 ## File path: streams/src/main/java/org/apache/kafka/streams/state/ReadOnlyKeyValueStore.java ## @@ -65,9 +66,10 @@ * Order is not guaranteed as b

[jira] [Updated] (KAFKA-13147) connection-close-total Metric Keeps Incrementing While Broker Down

[ https://issues.apache.org/jira/browse/KAFKA-13147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Russell updated KAFKA-13147: - Description: When the broker is down, the {code}connection-close-total{code} keeps incrementing

[jira] [Created] (KAFKA-13147) connection-close-total Metric Keeps Incrementing While Broker Down

Gary Russell created KAFKA-13147: Summary: connection-close-total Metric Keeps Incrementing While Broker Down Key: KAFKA-13147 URL: https://issues.apache.org/jira/browse/KAFKA-13147 Project: Kafka

[jira] [Updated] (KAFKA-13146) Consider client use cases for accessing controller endpoints

[ https://issues.apache.org/jira/browse/KAFKA-13146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-13146: Description: In KAFKA-13143, we dropped the Metadata from the controller APIs. We did this

[jira] [Created] (KAFKA-13146) Consider client use cases for accessing controller endpoints

Jason Gustafson created KAFKA-13146: --- Summary: Consider client use cases for accessing controller endpoints Key: KAFKA-13146 URL: https://issues.apache.org/jira/browse/KAFKA-13146 Project: Kafka

[GitHub] [kafka] hachikuji commented on pull request #11135: KAFKA-13143 Remove HandleMetadata from ControllerAPis as metadata is not completely implemented on KRaft controllers

hachikuji commented on pull request #11135: URL: https://github.com/apache/kafka/pull/11135#issuecomment-888469413 I filed https://issues.apache.org/jira/browse/KAFKA-13146 as a follow-up for after 3.0. -- This is an automated message from the Apache Git Service. To respond to the messag

[GitHub] [kafka] vvcephei commented on a change in pull request #11129: Fix for flaky test in StoreQueryIntegrationTest

vvcephei commented on a change in pull request #11129: URL: https://github.com/apache/kafka/pull/11129#discussion_r678481215 ## File path: streams/src/test/java/org/apache/kafka/streams/integration/StoreQueryIntegrationTest.java ## @@ -152,11 +150,17 @@ public void shouldQuer

[GitHub] [kafka] vvcephei commented on a change in pull request #11129: Fix for flaky test in StoreQueryIntegrationTest

vvcephei commented on a change in pull request #11129: URL: https://github.com/apache/kafka/pull/11129#discussion_r678478897 ## File path: streams/src/test/java/org/apache/kafka/streams/integration/StoreQueryIntegrationTest.java ## @@ -152,11 +150,17 @@ public void shouldQuer

[jira] [Resolved] (KAFKA-12851) Flaky Test RaftEventSimulationTest.canMakeProgressIfMajorityIsReachable

[ https://issues.apache.org/jira/browse/KAFKA-12851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-12851. - Resolution: Fixed > Flaky Test RaftEventSimulationTest.canMakeProgressIfMajorityIsReacha

[GitHub] [kafka] hachikuji merged pull request #11134: KAFKA-12851: Fix Raft partition simulation

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

[GitHub] [kafka] rajinisivaram merged pull request #11136: KAFKA-13141; Skip follower fetch offset update in leader if diverging epoch is present

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

[GitHub] [kafka] rajinisivaram commented on pull request #11136: KAFKA-13141; Skip follower fetch offset update in leader if diverging epoch is present

rajinisivaram commented on pull request #11136: URL: https://github.com/apache/kafka/pull/11136#issuecomment-888447146 @hachikuji Thanks for the review, merging to trunk, 3.0, 2.8 and 2.7. -- This is an automated message from the Apache Git Service. To respond to the message, please log o

[GitHub] [kafka] jlprat commented on pull request #10784: KAFKA-12862: Update Scala fmt library and apply fixes

jlprat commented on pull request #10784: URL: https://github.com/apache/kafka/pull/10784#issuecomment-888398307 Hi @vvcephei feel free to review the tiny commit to fix the code that has been committed since the PR was created. Also test failure seems unrelated -- This is an automated

[GitHub] [kafka] patrickstuedi commented on pull request #11120: Add support for infinite endpoints for range queries

patrickstuedi commented on pull request #11120: URL: https://github.com/apache/kafka/pull/11120#issuecomment-888334577 @showuon Thanks for catching the javadoc thing! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use th

[jira] [Commented] (KAFKA-10627) Connect TimestampConverter transform does not support multiple formats for the same field and only allows one field to be transformed at a time

[ https://issues.apache.org/jira/browse/KAFKA-10627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17388779#comment-17388779 ] Randall Hauch commented on KAFKA-10627: --- Thanks, [~joshuagrisham]! I've added you

[jira] [Assigned] (KAFKA-10627) Connect TimestampConverter transform does not support multiple formats for the same field and only allows one field to be transformed at a time

[ https://issues.apache.org/jira/browse/KAFKA-10627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch reassigned KAFKA-10627: - Assignee: Joshua Grisham > Connect TimestampConverter transform does not support multip

[jira] [Updated] (KAFKA-10627) Connect TimestampConverter transform does not support multiple formats for the same field and only allows one field to be transformed at a time

[ https://issues.apache.org/jira/browse/KAFKA-10627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-10627: -- Issue Type: New Feature (was: Improvement) > Connect TimestampConverter transform does not su

[jira] [Updated] (KAFKA-10627) Connect TimestampConverter transform does not support multiple formats for the same field and only allows one field to be transformed at a time

[ https://issues.apache.org/jira/browse/KAFKA-10627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-10627: -- Labels: connect-transformation need-kip (was: ) > Connect TimestampConverter transform does n

[GitHub] [kafka] rhauch commented on pull request #9492: KAFKA-10627: Added support for Connect TimestampConverter to convert multiple fields using a comma-separated list, and multiple input formats w

rhauch commented on pull request #9492: URL: https://github.com/apache/kafka/pull/9492#issuecomment-888308029 @joshuagrisham, would you mind taking a look and resolving the merge conflicts? Thanks! -- This is an automated message from the Apache Git Service. To respond to the message, pl

[GitHub] [kafka] rhauch edited a comment on pull request #9492: KAFKA-10627: Added support for Connect TimestampConverter to convert multiple fields using a comma-separated list, and multiple input fo

rhauch edited a comment on pull request #9492: URL: https://github.com/apache/kafka/pull/9492#issuecomment-888303589 Thanks for the contribution, and thanks for the KIP: https://cwiki.apache.org/confluence/display/KAFKA/KIP-682%3A+Connect+TimestampConverter+support+for+multiple+fields+and+m

[GitHub] [kafka] rhauch commented on pull request #9492: KAFKA-10627: Added support for Connect TimestampConverter to convert multiple fields using a comma-separated list, and multiple input formats w

rhauch commented on pull request #9492: URL: https://github.com/apache/kafka/pull/9492#issuecomment-888303589 Thanks for the contribution. Unfortunately, any changes to public APIs, including configuration parameters or changes in behavior, will require a KIP to be written, discussed and a

[jira] [Issue Comment Deleted] (KAFKA-12243) Add toString methods to some of the classes introduced by this Epic

[ https://issues.apache.org/jira/browse/KAFKA-12243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] loboxu updated KAFKA-12243: --- Comment: was deleted (was: [~jsancio] ,Is there a more detailed description of this problem. What classes n

[GitHub] [kafka] showuon commented on pull request #11124: [WIP] KAFKA-12839: use sessionWindow to represent SlidingWindows

showuon commented on pull request #11124: URL: https://github.com/apache/kafka/pull/11124#issuecomment-888268160 @ableegoldman , really glad we have the same thought about it! (high-five :) ) I created a jira ticket KAFKA-13145 for this renaming improvement, and see if there are other o

[GitHub] [kafka] socutes commented on pull request #11138: KAFKA-12932: Interfaces for SnapshotReader and SnapshotWriter

socutes commented on pull request #11138: URL: https://github.com/apache/kafka/pull/11138#issuecomment-888270734 @showuon @jsancio please help review this pr. 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] socutes opened a new pull request #11138: KAFKA-12932: Interfaces for SnapshotReader and SnapshotWriter

socutes opened a new pull request #11138: URL: https://github.com/apache/kafka/pull/11138 Change the snapshot API so that SnapshotWriter and SnapshotReader are interfaces. Change the existing types SnapshotWriter and SnapshotReader to use a different name and to implement the interfaces in

[jira] [Created] (KAFKA-13145) Renaming the time interval window for better understanding

Luke Chen created KAFKA-13145: - Summary: Renaming the time interval window for better understanding Key: KAFKA-13145 URL: https://issues.apache.org/jira/browse/KAFKA-13145 Project: Kafka Issue Ty

[jira] [Updated] (KAFKA-13144) Change the LOG level from DEBUG to WARN/ERROR for error traces when obtaining topic metadata

[ https://issues.apache.org/jira/browse/KAFKA-13144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fernando Blanch Calvete updated KAFKA-13144: Summary: Change the LOG level from DEBUG to WARN/ERROR for error traces wh

[jira] [Created] (KAFKA-13144) Change the LOG level from DEBUG to WARN/ERROR for error traces when obtaining topic metada

Fernando Blanch Calvete created KAFKA-13144: --- Summary: Change the LOG level from DEBUG to WARN/ERROR for error traces when obtaining topic metada Key: KAFKA-13144 URL: https://issues.apache.org/jira/brow

[GitHub] [kafka] wycccccc opened a new pull request #11137: KAFKA-13133 Replace EasyMock and PowerMock with Mockito for AbstractHerderTest

wycc opened a new pull request #11137: URL: https://github.com/apache/kafka/pull/11137 Development of EasyMock and PowerMock has stagnated while Mockito continues to be actively developed. With the new Java cadence, it's a problem to depend on libraries that do bytecode generation and

[GitHub] [kafka] rajinisivaram opened a new pull request #11136: KAFKA-13141; Skip follower fetch offset update in leader if diverging epoch is present

rajinisivaram opened a new pull request #11136: URL: https://github.com/apache/kafka/pull/11136 See https://issues.apache.org/jira/browse/KAFKA-13141 for the failing scenario. The PR skips follower fetch state for diverging epochs similar to the error case. ### Committer Checklist (