[jira] [Reopened] (KAFKA-15863) Handle push telemetry throttling with quota manager
[ https://issues.apache.org/jira/browse/KAFKA-15863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal reopened KAFKA-15863: --- Reopening to introduce metric quota. > Handle push telemetry throttling with quota manager > --- > > Key: KAFKA-15863 > URL: https://issues.apache.org/jira/browse/KAFKA-15863 > Project: Kafka > Issue Type: Sub-task >Reporter: Apoorv Mittal >Assignee: Apoorv Mittal >Priority: Major > > Details: https://github.com/apache/kafka/pull/14699#discussion_r1399714279 -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Resolved] (KAFKA-16744) Add support for share group describe in KafkaApis
[ https://issues.apache.org/jira/browse/KAFKA-16744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-16744. --- Resolution: Fixed > Add support for share group describe in KafkaApis > - > > Key: KAFKA-16744 > URL: https://issues.apache.org/jira/browse/KAFKA-16744 > Project: Kafka > Issue Type: Sub-task >Reporter: Apoorv Mittal >Assignee: Apoorv Mittal >Priority: Major > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Resolved] (KAFKA-16743) Add support for share group heartbeat in KafkaApis
[ https://issues.apache.org/jira/browse/KAFKA-16743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-16743. --- Resolution: Fixed > Add support for share group heartbeat in KafkaApis > -- > > Key: KAFKA-16743 > URL: https://issues.apache.org/jira/browse/KAFKA-16743 > Project: Kafka > Issue Type: Sub-task >Reporter: Apoorv Mittal >Assignee: Apoorv Mittal >Priority: Major > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Resolved] (KAFKA-16756) Implement max delivery count functionality in SharePartition
[ https://issues.apache.org/jira/browse/KAFKA-16756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-16756. --- Resolution: Done Already merged as part of other code changes in Share Partition. > Implement max delivery count functionality in SharePartition > > > Key: KAFKA-16756 > URL: https://issues.apache.org/jira/browse/KAFKA-16756 > Project: Kafka > Issue Type: Sub-task >Reporter: Apoorv Mittal >Assignee: Apoorv Mittal >Priority: Major > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Assigned] (KAFKA-16756) Implement max delivery count functionality in SharePartition
[ https://issues.apache.org/jira/browse/KAFKA-16756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal reassigned KAFKA-16756: - Assignee: Apoorv Mittal (was: Chirag Wadhwa) > Implement max delivery count functionality in SharePartition > > > Key: KAFKA-16756 > URL: https://issues.apache.org/jira/browse/KAFKA-16756 > Project: Kafka > Issue Type: Sub-task >Reporter: Apoorv Mittal >Assignee: Apoorv Mittal >Priority: Major > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Updated] (KAFKA-15807) Add support for compression/decompression of metrics
[ https://issues.apache.org/jira/browse/KAFKA-15807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal updated KAFKA-15807: -- Fix Version/s: 3.7.1 > Add support for compression/decompression of metrics > > > Key: KAFKA-15807 > URL: https://issues.apache.org/jira/browse/KAFKA-15807 > Project: Kafka > Issue Type: Sub-task >Reporter: Apoorv Mittal >Assignee: Apoorv Mittal >Priority: Major > Fix For: 3.7.1 > > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (KAFKA-17047) Refactor Consumer group and shared classes with Share to modern package
Apoorv Mittal created KAFKA-17047: - Summary: Refactor Consumer group and shared classes with Share to modern package Key: KAFKA-17047 URL: https://issues.apache.org/jira/browse/KAFKA-17047 Project: Kafka Issue Type: Sub-task Reporter: Apoorv Mittal Assignee: Apoorv Mittal -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (KAFKA-17040) Unknown telemetry state: TERMINATED thrown when closing AsyncKafkaConsumer
[
https://issues.apache.org/jira/browse/KAFKA-17040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17860012#comment-17860012
]
Apoorv Mittal commented on KAFKA-17040:
---
[~kirktrue] Thanks for reporting, I can take it up. Just a quick question, the
error only occurs while closing the consumer, correct? Is it under scenarios
when consumer close took more time than next network client poll time? I expect
that's the only scenario when this issue can occur. I am just wondering when
specifically this scenrio happens?
> Unknown telemetry state: TERMINATED thrown when closing AsyncKafkaConsumer
> --
>
> Key: KAFKA-17040
> URL: https://issues.apache.org/jira/browse/KAFKA-17040
> Project: Kafka
> Issue Type: Bug
> Components: clients, metrics
>Affects Versions: 3.9.0
>Reporter: Kirk True
>Assignee: Apoorv Mittal
>Priority: Major
>
> An error is occasionally thrown when closing the {{{}AsyncKafkaConsumer{}}}:
> {noformat}
> [ERROR] 2024-06-20 17:13:54,121 [consumer_background_thread]
> org.apache.kafka.clients.consumer.internals.ConsumerNetworkThread
> lambda$configureThread$0 - Uncaught exception in thread
> 'consumer_background_thread':
> java.lang.IllegalStateException: Unknown telemetry state: TERMINATED
> at
> org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter$DefaultClientTelemetrySender.timeToNextUpdate(ClientTelemetryReporter.java:363)
> at
> org.apache.kafka.clients.NetworkClient$TelemetrySender.maybeUpdate(NetworkClient.java:1392)
> at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:668)
> at
> org.apache.kafka.clients.consumer.internals.NetworkClientDelegate.poll(NetworkClientDelegate.java:143)
> at
> org.apache.kafka.clients.consumer.internals.ConsumerNetworkThread.sendUnsentRequests(ConsumerNetworkThread.java:299)
> at
> org.apache.kafka.clients.consumer.internals.ConsumerNetworkThread.cleanup(ConsumerNetworkThread.java:318)
> at
> org.apache.kafka.clients.consumer.internals.ConsumerNetworkThread.run(ConsumerNetworkThread.java:105){noformat}
> The issue appears to be that the {{TERMINATED}} state is not expected in the
> switch statement inside
> [timeToNextUpdate()|https://github.com/apache/kafka/blob/trunk/clients/src/main/java/org/apache/kafka/common/telemetry/internals/ClientTelemetryReporter.java#L307].
> As an aside, the error message might make more sense to be written as
> "{_}Unexpected{_} telemetry state" instead of "{_}Unknown{_} telemetry state"
> since {{TERMINATED}} is a known state, but heretofore unexpected.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
[jira] [Assigned] (KAFKA-17040) Unknown telemetry state: TERMINATED thrown when closing AsyncKafkaConsumer
[
https://issues.apache.org/jira/browse/KAFKA-17040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Apoorv Mittal reassigned KAFKA-17040:
-
Assignee: Apoorv Mittal
> Unknown telemetry state: TERMINATED thrown when closing AsyncKafkaConsumer
> --
>
> Key: KAFKA-17040
> URL: https://issues.apache.org/jira/browse/KAFKA-17040
> Project: Kafka
> Issue Type: Bug
> Components: clients, metrics
>Affects Versions: 3.9.0
>Reporter: Kirk True
>Assignee: Apoorv Mittal
>Priority: Major
>
> An error is occasionally thrown when closing the {{{}AsyncKafkaConsumer{}}}:
> {noformat}
> [ERROR] 2024-06-20 17:13:54,121 [consumer_background_thread]
> org.apache.kafka.clients.consumer.internals.ConsumerNetworkThread
> lambda$configureThread$0 - Uncaught exception in thread
> 'consumer_background_thread':
> java.lang.IllegalStateException: Unknown telemetry state: TERMINATED
> at
> org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter$DefaultClientTelemetrySender.timeToNextUpdate(ClientTelemetryReporter.java:363)
> at
> org.apache.kafka.clients.NetworkClient$TelemetrySender.maybeUpdate(NetworkClient.java:1392)
> at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:668)
> at
> org.apache.kafka.clients.consumer.internals.NetworkClientDelegate.poll(NetworkClientDelegate.java:143)
> at
> org.apache.kafka.clients.consumer.internals.ConsumerNetworkThread.sendUnsentRequests(ConsumerNetworkThread.java:299)
> at
> org.apache.kafka.clients.consumer.internals.ConsumerNetworkThread.cleanup(ConsumerNetworkThread.java:318)
> at
> org.apache.kafka.clients.consumer.internals.ConsumerNetworkThread.run(ConsumerNetworkThread.java:105){noformat}
> The issue appears to be that the {{TERMINATED}} state is not expected in the
> switch statement inside
> [timeToNextUpdate()|https://github.com/apache/kafka/blob/trunk/clients/src/main/java/org/apache/kafka/common/telemetry/internals/ClientTelemetryReporter.java#L307].
> As an aside, the error message might make more sense to be written as
> "{_}Unexpected{_} telemetry state" instead of "{_}Unknown{_} telemetry state"
> since {{TERMINATED}} is a known state, but heretofore unexpected.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
[jira] [Resolved] (KAFKA-16749) Implement share fetch messages
[ https://issues.apache.org/jira/browse/KAFKA-16749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-16749. --- Resolution: Done > Implement share fetch messages > -- > > Key: KAFKA-16749 > URL: https://issues.apache.org/jira/browse/KAFKA-16749 > Project: Kafka > Issue Type: Sub-task >Reporter: Apoorv Mittal >Assignee: Apoorv Mittal >Priority: Major > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Resolved] (KAFKA-16999) Integrate persister read API in Partition leader initilization
[ https://issues.apache.org/jira/browse/KAFKA-16999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-16999. --- Resolution: Done > Integrate persister read API in Partition leader initilization > -- > > Key: KAFKA-16999 > URL: https://issues.apache.org/jira/browse/KAFKA-16999 > Project: Kafka > Issue Type: Sub-task >Reporter: Apoorv Mittal >Assignee: Apoorv Mittal >Priority: Major > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Resolved] (KAFKA-16748) Implement share response handling in SharePartitionManager
[ https://issues.apache.org/jira/browse/KAFKA-16748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-16748. --- Resolution: Fixed > Implement share response handling in SharePartitionManager > -- > > Key: KAFKA-16748 > URL: https://issues.apache.org/jira/browse/KAFKA-16748 > Project: Kafka > Issue Type: Sub-task >Reporter: Apoorv Mittal >Assignee: Abhinav Dixit >Priority: Major > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (KAFKA-17002) Integrate partition leader epoch in Share Partition
Apoorv Mittal created KAFKA-17002: - Summary: Integrate partition leader epoch in Share Partition Key: KAFKA-17002 URL: https://issues.apache.org/jira/browse/KAFKA-17002 Project: Kafka Issue Type: Sub-task Reporter: Apoorv Mittal Assignee: Apoorv Mittal -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (KAFKA-16999) Integrate persister read API in Partition leader initilization
Apoorv Mittal created KAFKA-16999: - Summary: Integrate persister read API in Partition leader initilization Key: KAFKA-16999 URL: https://issues.apache.org/jira/browse/KAFKA-16999 Project: Kafka Issue Type: Sub-task Reporter: Apoorv Mittal Assignee: Apoorv Mittal -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Resolved] (KAFKA-16753) Implement acknowledge functionality in SharePartition
[ https://issues.apache.org/jira/browse/KAFKA-16753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-16753. --- Resolution: Fixed > Implement acknowledge functionality in SharePartition > - > > Key: KAFKA-16753 > URL: https://issues.apache.org/jira/browse/KAFKA-16753 > Project: Kafka > Issue Type: Sub-task >Reporter: Apoorv Mittal >Assignee: Apoorv Mittal >Priority: Major > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Resolved] (KAFKA-16752) Implement acquire functionality in SharePartition
[ https://issues.apache.org/jira/browse/KAFKA-16752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-16752. --- Resolution: Done > Implement acquire functionality in SharePartition > - > > Key: KAFKA-16752 > URL: https://issues.apache.org/jira/browse/KAFKA-16752 > Project: Kafka > Issue Type: Sub-task >Reporter: Apoorv Mittal >Assignee: Apoorv Mittal >Priority: Major > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Updated] (KAFKA-16950) Define Persister and Share Coordinator RPCs
[
https://issues.apache.org/jira/browse/KAFKA-16950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Apoorv Mittal updated KAFKA-16950:
--
Description:
Add Persister interface with schemas for RPCs. The classes which are needed by
SharePartition to integrate are below, note some of them results from the
generated json schema classes.
{code:java}
import org.apache.kafka.server.group.share.GroupTopicPartitionData;
import org.apache.kafka.server.group.share.PartitionAllData;
import org.apache.kafka.server.group.share.PartitionErrorData;
import org.apache.kafka.server.group.share.PartitionFactory;
import org.apache.kafka.server.group.share.PartitionIdLeaderEpochData;
import org.apache.kafka.server.group.share.PartitionStateBatchData;
import org.apache.kafka.server.group.share.Persister;
import org.apache.kafka.server.group.share.PersisterStateBatch;
import org.apache.kafka.server.group.share.ReadShareGroupStateParameters;
import org.apache.kafka.server.group.share.ReadShareGroupStateResult;
import org.apache.kafka.server.group.share.TopicData;
import org.apache.kafka.server.group.share.WriteShareGroupStateParameters;
import org.apache.kafka.server.group.share.WriteShareGroupStateResult; {code}
> Define Persister and Share Coordinator RPCs
> ---
>
> Key: KAFKA-16950
> URL: https://issues.apache.org/jira/browse/KAFKA-16950
> Project: Kafka
> Issue Type: Sub-task
>Reporter: Apoorv Mittal
>Priority: Major
>
> Add Persister interface with schemas for RPCs. The classes which are needed
> by SharePartition to integrate are below, note some of them results from the
> generated json schema classes.
>
>
> {code:java}
> import org.apache.kafka.server.group.share.GroupTopicPartitionData;
> import org.apache.kafka.server.group.share.PartitionAllData;
> import org.apache.kafka.server.group.share.PartitionErrorData;
> import org.apache.kafka.server.group.share.PartitionFactory;
> import org.apache.kafka.server.group.share.PartitionIdLeaderEpochData;
> import org.apache.kafka.server.group.share.PartitionStateBatchData;
> import org.apache.kafka.server.group.share.Persister;
> import org.apache.kafka.server.group.share.PersisterStateBatch;
> import org.apache.kafka.server.group.share.ReadShareGroupStateParameters;
> import org.apache.kafka.server.group.share.ReadShareGroupStateResult;
> import org.apache.kafka.server.group.share.TopicData;
> import org.apache.kafka.server.group.share.WriteShareGroupStateParameters;
> import org.apache.kafka.server.group.share.WriteShareGroupStateResult; {code}
>
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
[jira] [Created] (KAFKA-16950) Define Persister and Share Coordinator RPCs
Apoorv Mittal created KAFKA-16950: - Summary: Define Persister and Share Coordinator RPCs Key: KAFKA-16950 URL: https://issues.apache.org/jira/browse/KAFKA-16950 Project: Kafka Issue Type: Sub-task Reporter: Apoorv Mittal -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (KAFKA-16914) Add Shage Group dynamic and broker configs
Apoorv Mittal created KAFKA-16914: - Summary: Add Shage Group dynamic and broker configs Key: KAFKA-16914 URL: https://issues.apache.org/jira/browse/KAFKA-16914 Project: Kafka Issue Type: Sub-task Affects Versions: 4.0.0 Reporter: Apoorv Mittal Assignee: Abhinav Dixit Fix For: 4.0.0 Add the configs required for share group in KafkaConfig or equivalent. -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Assigned] (KAFKA-16743) Add support for share group heartbeat in KafkaApis
[ https://issues.apache.org/jira/browse/KAFKA-16743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal reassigned KAFKA-16743: - Assignee: Apoorv Mittal (was: Abhinav Dixit) > Add support for share group heartbeat in KafkaApis > -- > > Key: KAFKA-16743 > URL: https://issues.apache.org/jira/browse/KAFKA-16743 > Project: Kafka > Issue Type: Sub-task >Reporter: Apoorv Mittal >Assignee: Apoorv Mittal >Priority: Major > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (KAFKA-16905) Thread block in describe topics API in Admin Client
Apoorv Mittal created KAFKA-16905:
-
Summary: Thread block in describe topics API in Admin Client
Key: KAFKA-16905
URL: https://issues.apache.org/jira/browse/KAFKA-16905
Project: Kafka
Issue Type: Bug
Components: clients
Affects Versions: 3.9.0
Reporter: Apoorv Mittal
Assignee: Apoorv Mittal
Fix For: 3.9.0
The threads blocks while running admin client's descirbe topics API.
{code:java}
"kafka-admin-client-thread | adminclient-3" #114 daemon prio=5 os_prio=31
cpu=6.57ms elapsed=417.17s tid=0x0001364fc200 nid=0x13403 waiting on
condition [0x0002bb419000]
java.lang.Thread.State: WAITING (parking)
at jdk.internal.misc.Unsafe.park(java.base@17.0.7/Native Method)
- parking to wait for <0x000773804828> (a
java.util.concurrent.CompletableFuture$Signaller)
at
java.util.concurrent.locks.LockSupport.park(java.base@17.0.7/LockSupport.java:211)
at
java.util.concurrent.CompletableFuture$Signaller.block(java.base@17.0.7/CompletableFuture.java:1864)
at
java.util.concurrent.ForkJoinPool.unmanagedBlock(java.base@17.0.7/ForkJoinPool.java:3463)
at
java.util.concurrent.ForkJoinPool.managedBlock(java.base@17.0.7/ForkJoinPool.java:3434)
at
java.util.concurrent.CompletableFuture.waitingGet(java.base@17.0.7/CompletableFuture.java:1898)
at
java.util.concurrent.CompletableFuture.get(java.base@17.0.7/CompletableFuture.java:2072)
at
org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:165)
at
org.apache.kafka.clients.admin.KafkaAdminClient.handleDescribeTopicsByNamesWithDescribeTopicPartitionsApi(KafkaAdminClient.java:2324)
at
org.apache.kafka.clients.admin.KafkaAdminClient.describeTopics(KafkaAdminClient.java:2122)
at org.apache.kafka.clients.admin.Admin.describeTopics(Admin.java:311)
at
io.confluent.kafkarest.controllers.TopicManagerImpl.describeTopics(TopicManagerImpl.java:155)
at
io.confluent.kafkarest.controllers.TopicManagerImpl.lambda$listTopics$2(TopicManagerImpl.java:76)
at
io.confluent.kafkarest.controllers.TopicManagerImpl$$Lambda$1925/0x000800891448.apply(Unknown
Source)
at
java.util.concurrent.CompletableFuture$UniCompose.tryFire(java.base@17.0.7/CompletableFuture.java:1150)
at
java.util.concurrent.CompletableFuture.postComplete(java.base@17.0.7/CompletableFuture.java:510)
at
java.util.concurrent.CompletableFuture.complete(java.base@17.0.7/CompletableFuture.java:2147)
at
io.confluent.kafkarest.common.KafkaFutures.lambda$toCompletableFuture$0(KafkaFutures.java:45)
at
io.confluent.kafkarest.common.KafkaFutures$$Lambda$1909/0x000800897528.accept(Unknown
Source)
at
org.apache.kafka.common.internals.KafkaFutureImpl.lambda$whenComplete$2(KafkaFutureImpl.java:107)
at
org.apache.kafka.common.internals.KafkaFutureImpl$$Lambda$1910/0x000800897750.accept(Unknown
Source)
at
java.util.concurrent.CompletableFuture.uniWhenComplete(java.base@17.0.7/CompletableFuture.java:863)
at
java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(java.base@17.0.7/CompletableFuture.java:841)
at
java.util.concurrent.CompletableFuture.postComplete(java.base@17.0.7/CompletableFuture.java:510)
at
java.util.concurrent.CompletableFuture.complete(java.base@17.0.7/CompletableFuture.java:2147)
at
org.apache.kafka.common.internals.KafkaCompletableFuture.kafkaComplete(KafkaCompletableFuture.java:39)
at
org.apache.kafka.common.internals.KafkaFutureImpl.complete(KafkaFutureImpl.java:122)
at
org.apache.kafka.clients.admin.KafkaAdminClient$4.handleResponse(KafkaAdminClient.java:2106)
at
org.apache.kafka.clients.admin.KafkaAdminClient$AdminClientRunnable.handleResponses(KafkaAdminClient.java:1370)
at
org.apache.kafka.clients.admin.KafkaAdminClient$AdminClientRunnable.processRequests(KafkaAdminClient.java:1523)
at
org.apache.kafka.clients.admin.KafkaAdminClient$AdminClientRunnable.run(KafkaAdminClient.java:1446)
at java.lang.Thread.run(java.base@17.0.7/Thread.java:833) {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
[jira] [Created] (KAFKA-16822) Abstract consumer group in coordinator to share functionality with share group
Apoorv Mittal created KAFKA-16822: - Summary: Abstract consumer group in coordinator to share functionality with share group Key: KAFKA-16822 URL: https://issues.apache.org/jira/browse/KAFKA-16822 Project: Kafka Issue Type: Sub-task Reporter: Apoorv Mittal Assignee: Apoorv Mittal -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (KAFKA-16756) Implement max delivery count functionality in SharePartition
Apoorv Mittal created KAFKA-16756: - Summary: Implement max delivery count functionality in SharePartition Key: KAFKA-16756 URL: https://issues.apache.org/jira/browse/KAFKA-16756 Project: Kafka Issue Type: Sub-task Reporter: Apoorv Mittal Assignee: Chirag Wadhwa -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (KAFKA-16753) Implement acknowledge functionality in SharePartition
Apoorv Mittal created KAFKA-16753: - Summary: Implement acknowledge functionality in SharePartition Key: KAFKA-16753 URL: https://issues.apache.org/jira/browse/KAFKA-16753 Project: Kafka Issue Type: Sub-task Reporter: Apoorv Mittal Assignee: Apoorv Mittal -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (KAFKA-16755) Implement lock timeout functionality in SharePartition
Apoorv Mittal created KAFKA-16755: - Summary: Implement lock timeout functionality in SharePartition Key: KAFKA-16755 URL: https://issues.apache.org/jira/browse/KAFKA-16755 Project: Kafka Issue Type: Sub-task Reporter: Apoorv Mittal Assignee: Abhinav Dixit -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (KAFKA-16754) Implement release acquired records functionality in SharePartition
Apoorv Mittal created KAFKA-16754: - Summary: Implement release acquired records functionality in SharePartition Key: KAFKA-16754 URL: https://issues.apache.org/jira/browse/KAFKA-16754 Project: Kafka Issue Type: Sub-task Reporter: Apoorv Mittal Assignee: Abhinav Dixit -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (KAFKA-16752) Implement acquire functionality in SharePartition
Apoorv Mittal created KAFKA-16752: - Summary: Implement acquire functionality in SharePartition Key: KAFKA-16752 URL: https://issues.apache.org/jira/browse/KAFKA-16752 Project: Kafka Issue Type: Sub-task Reporter: Apoorv Mittal Assignee: Apoorv Mittal -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (KAFKA-16750) Implement acknowledge API in SharePartitionManager
Apoorv Mittal created KAFKA-16750: - Summary: Implement acknowledge API in SharePartitionManager Key: KAFKA-16750 URL: https://issues.apache.org/jira/browse/KAFKA-16750 Project: Kafka Issue Type: Sub-task Reporter: Apoorv Mittal Assignee: Chirag Wadhwa -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (KAFKA-16751) Implement release acquired records in SharePartitionManager
Apoorv Mittal created KAFKA-16751: - Summary: Implement release acquired records in SharePartitionManager Key: KAFKA-16751 URL: https://issues.apache.org/jira/browse/KAFKA-16751 Project: Kafka Issue Type: Sub-task Reporter: Apoorv Mittal Assignee: Abhinav Dixit -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (KAFKA-16749) Implement share fetch messages
Apoorv Mittal created KAFKA-16749: - Summary: Implement share fetch messages Key: KAFKA-16749 URL: https://issues.apache.org/jira/browse/KAFKA-16749 Project: Kafka Issue Type: Sub-task Reporter: Apoorv Mittal Assignee: Apoorv Mittal -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (KAFKA-16747) Implement share sessions and context
Apoorv Mittal created KAFKA-16747: - Summary: Implement share sessions and context Key: KAFKA-16747 URL: https://issues.apache.org/jira/browse/KAFKA-16747 Project: Kafka Issue Type: Sub-task Reporter: Apoorv Mittal Assignee: Abhinav Dixit -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (KAFKA-16748) Implement share response handling in SharePartitionManager
Apoorv Mittal created KAFKA-16748: - Summary: Implement share response handling in SharePartitionManager Key: KAFKA-16748 URL: https://issues.apache.org/jira/browse/KAFKA-16748 Project: Kafka Issue Type: Sub-task Reporter: Apoorv Mittal Assignee: Abhinav Dixit -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Assigned] (KAFKA-16743) Add support for share group heartbeat in KafkaApis
[ https://issues.apache.org/jira/browse/KAFKA-16743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal reassigned KAFKA-16743: - Assignee: Abhinav Dixit > Add support for share group heartbeat in KafkaApis > -- > > Key: KAFKA-16743 > URL: https://issues.apache.org/jira/browse/KAFKA-16743 > Project: Kafka > Issue Type: Sub-task >Reporter: Apoorv Mittal >Assignee: Abhinav Dixit >Priority: Major > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (KAFKA-16746) Add support for share acknowledgement request in KafkaApis
Apoorv Mittal created KAFKA-16746: - Summary: Add support for share acknowledgement request in KafkaApis Key: KAFKA-16746 URL: https://issues.apache.org/jira/browse/KAFKA-16746 Project: Kafka Issue Type: Sub-task Reporter: Apoorv Mittal Assignee: Chirag Wadhwa -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (KAFKA-16745) Add support for share fetch request in KafkaApis
Apoorv Mittal created KAFKA-16745: - Summary: Add support for share fetch request in KafkaApis Key: KAFKA-16745 URL: https://issues.apache.org/jira/browse/KAFKA-16745 Project: Kafka Issue Type: Sub-task Reporter: Apoorv Mittal Assignee: Chirag Wadhwa -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (KAFKA-16744) Add support for share group describe in KafkaApis
Apoorv Mittal created KAFKA-16744: - Summary: Add support for share group describe in KafkaApis Key: KAFKA-16744 URL: https://issues.apache.org/jira/browse/KAFKA-16744 Project: Kafka Issue Type: Sub-task Reporter: Apoorv Mittal Assignee: Apoorv Mittal -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (KAFKA-16743) Add support for share group heartbeat in KafkaApis
Apoorv Mittal created KAFKA-16743: - Summary: Add support for share group heartbeat in KafkaApis Key: KAFKA-16743 URL: https://issues.apache.org/jira/browse/KAFKA-16743 Project: Kafka Issue Type: Sub-task Reporter: Apoorv Mittal -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (KAFKA-16741) Add SharGroupHeartbeat API support in GroupCoordinator
Apoorv Mittal created KAFKA-16741: - Summary: Add SharGroupHeartbeat API support in GroupCoordinator Key: KAFKA-16741 URL: https://issues.apache.org/jira/browse/KAFKA-16741 Project: Kafka Issue Type: Sub-task Reporter: Apoorv Mittal Assignee: Apoorv Mittal -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (KAFKA-16742) Add ShareGroupDescribe API support in GroupCoordinator
Apoorv Mittal created KAFKA-16742: - Summary: Add ShareGroupDescribe API support in GroupCoordinator Key: KAFKA-16742 URL: https://issues.apache.org/jira/browse/KAFKA-16742 Project: Kafka Issue Type: Sub-task Reporter: Apoorv Mittal Assignee: Apoorv Mittal -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (KAFKA-16740) Define skeleton for SharePartitionManager and SharePartition
Apoorv Mittal created KAFKA-16740: - Summary: Define skeleton for SharePartitionManager and SharePartition Key: KAFKA-16740 URL: https://issues.apache.org/jira/browse/KAFKA-16740 Project: Kafka Issue Type: Sub-task Reporter: Apoorv Mittal Assignee: Apoorv Mittal Add high level design for broker side implementation for fetching and acknowledging messages. -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (KAFKA-15850) Improve KafkaMetrics APIs to expose Value Provider information
[ https://issues.apache.org/jira/browse/KAFKA-15850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839657#comment-17839657 ] Apoorv Mittal commented on KAFKA-15850: --- This has been completed as part of KIP-1019. Resolving the issue. > Improve KafkaMetrics APIs to expose Value Provider information > -- > > Key: KAFKA-15850 > URL: https://issues.apache.org/jira/browse/KAFKA-15850 > Project: Kafka > Issue Type: Sub-task >Reporter: Apoorv Mittal >Assignee: Apoorv Mittal >Priority: Major > > Today KafkaMetric do not expose the metricValueProvider information which > makes it hard to determine the provider type. In KIP-714 implementation we > have used reflections to access the information but would like to propose the > correct ways of exposing the information. > Discussion thread: > https://github.com/apache/kafka/pull/14620#discussion_r1374059672 -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (KAFKA-16492) Flaky test: testAlterSinkConnectorOffsetsDifferentKafkaClusterTargeted – org.apache.kafka.connect.integration.OffsetsApiIntegrationTest
Apoorv Mittal created KAFKA-16492:
-
Summary: Flaky test:
testAlterSinkConnectorOffsetsDifferentKafkaClusterTargeted –
org.apache.kafka.connect.integration.OffsetsApiIntegrationTest
Key: KAFKA-16492
URL: https://issues.apache.org/jira/browse/KAFKA-16492
Project: Kafka
Issue Type: Bug
Reporter: Apoorv Mittal
Build:
[https://ci-builds.apache.org/blue/organizations/jenkins/Kafka%2Fkafka-pr/detail/PR-15680/1/tests/]
{code:java}
Errororg.opentest4j.AssertionFailedError: Condition not met within timeout
3. Sink connector consumer group offsets should catch up to the topic end
offsets ==> expected: but was:
Stacktraceorg.opentest4j.AssertionFailedError: Condition not met within
timeout 3. Sink connector consumer group offsets should catch up to the
topic end offsets ==> expected: but was:at
app//org.junit.jupiter.api.AssertionFailureBuilder.build(AssertionFailureBuilder.java:151)
at
app//org.junit.jupiter.api.AssertionFailureBuilder.buildAndThrow(AssertionFailureBuilder.java:132)
at app//org.junit.jupiter.api.AssertTrue.failNotTrue(AssertTrue.java:63)
at app//org.junit.jupiter.api.AssertTrue.assertTrue(AssertTrue.java:36) at
app//org.junit.jupiter.api.Assertions.assertTrue(Assertions.java:214)at
app//org.apache.kafka.test.TestUtils.lambda$waitForCondition$3(TestUtils.java:396)
at
app//org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:444)
at app//org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:393)
at app//org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:377)
at app//org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:367)
at
app//org.apache.kafka.connect.integration.OffsetsApiIntegrationTest.verifyExpectedSinkConnectorOffsets(OffsetsApiIntegrationTest.java:989)
at
app//org.apache.kafka.connect.integration.OffsetsApiIntegrationTest.alterAndVerifySinkConnectorOffsets(OffsetsApiIntegrationTest.java:381)
at
app//org.apache.kafka.connect.integration.OffsetsApiIntegrationTest.testAlterSinkConnectorOffsetsDifferentKafkaClusterTargeted(OffsetsApiIntegrationTest.java:362)
at
java.base@11.0.16.1/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native
Method) at
java.base@11.0.16.1/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
java.base@11.0.16.1/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.base@11.0.16.1/java.lang.reflect.Method.invoke(Method.java:566) at
app//org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
at
app//org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at
app//org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
at
app//org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at
app//org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
at
app//org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
at app//org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:61) at
app//org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)at
app//org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100)
at app//org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366) at
app//org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103)
at
app//org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63)
at app//org.junit.runners.ParentRunner$4.run(ParentRunner.java:331)
at app//org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79) at
app//org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329) at
app//org.junit.runners.ParentRunner.access$100(ParentRunner.java:66) at
app//org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293)at
app//org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
at app//org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
at app//org.junit.runners.ParentRunner.run(ParentRunner.java:413) at
org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecutor.runTestClass(JUnitTestClassExecutor.java:112)
at
org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecutor.execute(JUnitTestClassExecutor.java:58)
at
org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecutor.execute(JUnitTestClassExecutor.java:40)
at
org.gradle.api.internal.tasks.testing.junit.AbstractJUnitTestClassProcessor.processTestClass(AbstractJUnitTestClassProcessor.java:60)
at
org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:52)
[jira] [Created] (KAFKA-16491) Flaky test: randomClusterPerturbationsShouldConverge[rackAwareStrategy=balance_subtopology] – org.apache.kafka.streams.processor.internals.assignment.TaskAssignorConverg
Apoorv Mittal created KAFKA-16491:
-
Summary: Flaky test:
randomClusterPerturbationsShouldConverge[rackAwareStrategy=balance_subtopology]
–
org.apache.kafka.streams.processor.internals.assignment.TaskAssignorConvergenceTest
Key: KAFKA-16491
URL: https://issues.apache.org/jira/browse/KAFKA-16491
Project: Kafka
Issue Type: Bug
Reporter: Apoorv Mittal
Build:
https://ci-builds.apache.org/blue/organizations/jenkins/Kafka%2Fkafka-pr/detail/PR-15680/1/tests/
{code:java}
Errorjava.lang.AssertionError: Assertion failed in randomized test. Reproduce
with:
`runRandomizedScenario(-3500059697111741230)`.Stacktracejava.lang.AssertionError:
Assertion failed in randomized test. Reproduce with:
`runRandomizedScenario(-3500059697111741230)`. at
org.apache.kafka.streams.processor.internals.assignment.TaskAssignorConvergenceTest.runRandomizedScenario(TaskAssignorConvergenceTest.java:545)
at
org.apache.kafka.streams.processor.internals.assignment.TaskAssignorConvergenceTest.randomClusterPerturbationsShouldConverge(TaskAssignorConvergenceTest.java:479)
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native
Method) at
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
at
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.base/java.lang.reflect.Method.invoke(Method.java:568) at
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
at
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at
org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
at
org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at
org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306) at
org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366)at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103)
at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63)
at org.junit.runners.ParentRunner$4.run(ParentRunner.java:331) at
org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79) at
org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329)at
org.junit.runners.ParentRunner.access$100(ParentRunner.java:66) at
org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293) at
org.junit.runners.ParentRunner.run(ParentRunner.java:413)at
org.junit.runners.Suite.runChild(Suite.java:128) at
org.junit.runners.Suite.runChild(Suite.java:27) at
org.junit.runners.ParentRunner$4.run(ParentRunner.java:331) at
org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79) at
org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329)at
org.junit.runners.ParentRunner.access$100(ParentRunner.java:66) at
org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293) at
org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306) at
org.junit.runners.ParentRunner.run(ParentRunner.java:413)at
org.junit.runner.JUnitCore.run(JUnitCore.java:137) at
org.junit.runner.JUnitCore.run(JUnitCore.java:115) at
org.junit.vintage.engine.execution.RunnerExecutor.execute(RunnerExecutor.java:42)
at
org.junit.vintage.engine.VintageTestEngine.executeAllChildren(VintageTestEngine.java:80)
at
org.junit.vintage.engine.VintageTestEngine.execute(VintageTestEngine.java:72)
at
org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:107)
at
org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:88)
at
org.junit.platform.launcher.core.EngineExecutionOrchestrator.lambda$execute$0(EngineExecutionOrchestrator.java:54){code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
[jira] [Created] (KAFKA-16486) Integrate metric measurability changes in metrics collector
Apoorv Mittal created KAFKA-16486: - Summary: Integrate metric measurability changes in metrics collector Key: KAFKA-16486 URL: https://issues.apache.org/jira/browse/KAFKA-16486 Project: Kafka Issue Type: Sub-task Reporter: Apoorv Mittal Assignee: Apoorv Mittal -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Updated] (KAFKA-16485) Fix broker metrics to follow kebab/hyphen case
[ https://issues.apache.org/jira/browse/KAFKA-16485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal updated KAFKA-16485: -- Parent: KAFKA-15601 Issue Type: Sub-task (was: Improvement) > Fix broker metrics to follow kebab/hyphen case > -- > > Key: KAFKA-16485 > URL: https://issues.apache.org/jira/browse/KAFKA-16485 > Project: Kafka > Issue Type: Sub-task >Reporter: Apoorv Mittal >Assignee: Apoorv Mittal >Priority: Major > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (KAFKA-16485) Fix broker metrics to follow kebab/hyphen case
Apoorv Mittal created KAFKA-16485: - Summary: Fix broker metrics to follow kebab/hyphen case Key: KAFKA-16485 URL: https://issues.apache.org/jira/browse/KAFKA-16485 Project: Kafka Issue Type: Improvement Reporter: Apoorv Mittal Assignee: Apoorv Mittal -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (KAFKA-16397) Use ByteBufferOutputStream to avoid array copy
[ https://issues.apache.org/jira/browse/KAFKA-16397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17829519#comment-17829519 ] Apoorv Mittal commented on KAFKA-16397: --- [~chia7712] Yes please, go ahead. > Use ByteBufferOutputStream to avoid array copy > -- > > Key: KAFKA-16397 > URL: https://issues.apache.org/jira/browse/KAFKA-16397 > Project: Kafka > Issue Type: Improvement >Reporter: Chia-Ping Tsai >Priority: Minor > > from https://github.com/apache/kafka/pull/15148#discussion_r1531889679 > source code: > https://github.com/apache/kafka/blob/trunk/clients/src/main/java/org/apache/kafka/common/telemetry/internals/ClientTelemetryUtils.java#L216 > we can use ByteBufferOutputStream to collect the uncompressed data, and then > return the inner buffer directly instead of copying full array. -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Assigned] (KAFKA-16397) Use ByteBufferOutputStream to avoid array copy
[ https://issues.apache.org/jira/browse/KAFKA-16397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal reassigned KAFKA-16397: - Assignee: Chia-Ping Tsai > Use ByteBufferOutputStream to avoid array copy > -- > > Key: KAFKA-16397 > URL: https://issues.apache.org/jira/browse/KAFKA-16397 > Project: Kafka > Issue Type: Improvement >Reporter: Chia-Ping Tsai >Assignee: Chia-Ping Tsai >Priority: Minor > > from https://github.com/apache/kafka/pull/15148#discussion_r1531889679 > source code: > https://github.com/apache/kafka/blob/trunk/clients/src/main/java/org/apache/kafka/common/telemetry/internals/ClientTelemetryUtils.java#L216 > we can use ByteBufferOutputStream to collect the uncompressed data, and then > return the inner buffer directly instead of copying full array. -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (KAFKA-16359) kafka-clients-3.7.0.jar published to Maven Central is defective
[
https://issues.apache.org/jira/browse/KAFKA-16359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17826885#comment-17826885
]
Apoorv Mittal commented on KAFKA-16359:
---
[~ijuma] here is the fix [https://github.com/apache/kafka/pull/15532], the PR
description explains why we require code from plugin extracted.
> kafka-clients-3.7.0.jar published to Maven Central is defective
> ---
>
> Key: KAFKA-16359
> URL: https://issues.apache.org/jira/browse/KAFKA-16359
> Project: Kafka
> Issue Type: Bug
> Components: clients
>Affects Versions: 3.7.0
>Reporter: Jeremy Norris
>Assignee: Apoorv Mittal
>Priority: Critical
>
> The {{kafka-clients-3.7.0.jar}} that has been published to Maven Central is
> defective: it's {{META-INF/MANIFEST.MF}} bogusly include a {{Class-Path}}
> element:
> {code}
> Manifest-Version: 1.0
> Class-Path: zstd-jni-1.5.5-6.jar lz4-java-1.8.0.jar snappy-java-1.1.10
> .5.jar slf4j-api-1.7.36.jar
> {code}
> This bogus {{Class-Path}} element leads to compiler warnings for projects
> that utilize it as a dependency:
> {code}
> [WARNING] [path] bad path element
> ".../.m2/repository/org/apache/kafka/kafka-clients/3.7.0/zstd-jni-1.5.5-6.jar":
> no such file or directory
> [WARNING] [path] bad path element
> ".../.m2/repository/org/apache/kafka/kafka-clients/3.7.0/lz4-java-1.8.0.jar":
> no such file or directory
> [WARNING] [path] bad path element
> ".../.m2/repository/org/apache/kafka/kafka-clients/3.7.0/snappy-java-1.1.10.5.jar":
> no such file or directory
> [WARNING] [path] bad path element
> ".../.m2/repository/org/apache/kafka/kafka-clients/3.7.0/slf4j-api-1.7.36.jar":
> no such file or directory
> {code}
> Either the {{kafka-clients-3.7.0.jar}} needs to be respun and published
> without the bogus {{Class-Path}} element in it's {{META-INF/MANIFEST.MF}} or
> a new release should be published that corrects this defect.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
[jira] [Commented] (KAFKA-16359) kafka-clients-3.7.0.jar published to Maven Central is defective
[
https://issues.apache.org/jira/browse/KAFKA-16359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17825772#comment-17825772
]
Apoorv Mittal commented on KAFKA-16359:
---
Though by the time fix and release happens, below workaround might suppress the
warning for now (not a good practice but a workaround for now):
{code:java}
org.apache.maven.plugins
maven-compiler-plugin
true
true
true
...
...
-Xlint:-path
...
{code}
Similar shadow jar issue encountered by launchdarkly and others, reference
https://github.com/launchdarkly/java-server-sdk/issues/240
> kafka-clients-3.7.0.jar published to Maven Central is defective
> ---
>
> Key: KAFKA-16359
> URL: https://issues.apache.org/jira/browse/KAFKA-16359
> Project: Kafka
> Issue Type: Bug
> Components: clients
>Affects Versions: 3.7.0
>Reporter: Jeremy Norris
>Assignee: Apoorv Mittal
>Priority: Critical
>
> The {{kafka-clients-3.7.0.jar}} that has been published to Maven Central is
> defective: it's {{META-INF/MANIFEST.MF}} bogusly include a {{Class-Path}}
> element:
> {code}
> Manifest-Version: 1.0
> Class-Path: zstd-jni-1.5.5-6.jar lz4-java-1.8.0.jar snappy-java-1.1.10
> .5.jar slf4j-api-1.7.36.jar
> {code}
> This bogus {{Class-Path}} element leads to compiler warnings for projects
> that utilize it as a dependency:
> {code}
> [WARNING] [path] bad path element
> ".../.m2/repository/org/apache/kafka/kafka-clients/3.7.0/zstd-jni-1.5.5-6.jar":
> no such file or directory
> [WARNING] [path] bad path element
> ".../.m2/repository/org/apache/kafka/kafka-clients/3.7.0/lz4-java-1.8.0.jar":
> no such file or directory
> [WARNING] [path] bad path element
> ".../.m2/repository/org/apache/kafka/kafka-clients/3.7.0/snappy-java-1.1.10.5.jar":
> no such file or directory
> [WARNING] [path] bad path element
> ".../.m2/repository/org/apache/kafka/kafka-clients/3.7.0/slf4j-api-1.7.36.jar":
> no such file or directory
> {code}
> Either the {{kafka-clients-3.7.0.jar}} needs to be respun and published
> without the bogus {{Class-Path}} element in it's {{META-INF/MANIFEST.MF}} or
> a new release should be published that corrects this defect.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
[jira] [Assigned] (KAFKA-16359) kafka-clients-3.7.0.jar published to Maven Central is defective
[
https://issues.apache.org/jira/browse/KAFKA-16359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Apoorv Mittal reassigned KAFKA-16359:
-
Assignee: Apoorv Mittal
> kafka-clients-3.7.0.jar published to Maven Central is defective
> ---
>
> Key: KAFKA-16359
> URL: https://issues.apache.org/jira/browse/KAFKA-16359
> Project: Kafka
> Issue Type: Bug
> Components: clients
>Affects Versions: 3.7.0
>Reporter: Jeremy Norris
>Assignee: Apoorv Mittal
>Priority: Critical
>
> The {{kafka-clients-3.7.0.jar}} that has been published to Maven Central is
> defective: it's {{META-INF/MANIFEST.MF}} bogusly include a {{Class-Path}}
> element:
> {code}
> Manifest-Version: 1.0
> Class-Path: zstd-jni-1.5.5-6.jar lz4-java-1.8.0.jar snappy-java-1.1.10
> .5.jar slf4j-api-1.7.36.jar
> {code}
> This bogus {{Class-Path}} element leads to compiler warnings for projects
> that utilize it as a dependency:
> {code}
> [WARNING] [path] bad path element
> ".../.m2/repository/org/apache/kafka/kafka-clients/3.7.0/zstd-jni-1.5.5-6.jar":
> no such file or directory
> [WARNING] [path] bad path element
> ".../.m2/repository/org/apache/kafka/kafka-clients/3.7.0/lz4-java-1.8.0.jar":
> no such file or directory
> [WARNING] [path] bad path element
> ".../.m2/repository/org/apache/kafka/kafka-clients/3.7.0/snappy-java-1.1.10.5.jar":
> no such file or directory
> [WARNING] [path] bad path element
> ".../.m2/repository/org/apache/kafka/kafka-clients/3.7.0/slf4j-api-1.7.36.jar":
> no such file or directory
> {code}
> Either the {{kafka-clients-3.7.0.jar}} needs to be respun and published
> without the bogus {{Class-Path}} element in it's {{META-INF/MANIFEST.MF}} or
> a new release should be published that corrects this defect.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
[jira] [Commented] (KAFKA-16359) kafka-clients-3.7.0.jar published to Maven Central is defective
[
https://issues.apache.org/jira/browse/KAFKA-16359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17825333#comment-17825333
]
Apoorv Mittal commented on KAFKA-16359:
---
Hi [~norrisjeremy] , thanks for reporting the issue. As [~gnarula] mentioned
this comes as part of shadow plugin, I will look into the issue and should come
back with right resolution.
> kafka-clients-3.7.0.jar published to Maven Central is defective
> ---
>
> Key: KAFKA-16359
> URL: https://issues.apache.org/jira/browse/KAFKA-16359
> Project: Kafka
> Issue Type: Bug
> Components: clients
>Affects Versions: 3.7.0
>Reporter: Jeremy Norris
>Assignee: Apoorv Mittal
>Priority: Critical
>
> The {{kafka-clients-3.7.0.jar}} that has been published to Maven Central is
> defective: it's {{META-INF/MANIFEST.MF}} bogusly include a {{Class-Path}}
> element:
> {code}
> Manifest-Version: 1.0
> Class-Path: zstd-jni-1.5.5-6.jar lz4-java-1.8.0.jar snappy-java-1.1.10
> .5.jar slf4j-api-1.7.36.jar
> {code}
> This bogus {{Class-Path}} element leads to compiler warnings for projects
> that utilize it as a dependency:
> {code}
> [WARNING] [path] bad path element
> ".../.m2/repository/org/apache/kafka/kafka-clients/3.7.0/zstd-jni-1.5.5-6.jar":
> no such file or directory
> [WARNING] [path] bad path element
> ".../.m2/repository/org/apache/kafka/kafka-clients/3.7.0/lz4-java-1.8.0.jar":
> no such file or directory
> [WARNING] [path] bad path element
> ".../.m2/repository/org/apache/kafka/kafka-clients/3.7.0/snappy-java-1.1.10.5.jar":
> no such file or directory
> [WARNING] [path] bad path element
> ".../.m2/repository/org/apache/kafka/kafka-clients/3.7.0/slf4j-api-1.7.36.jar":
> no such file or directory
> {code}
> Either the {{kafka-clients-3.7.0.jar}} needs to be respun and published
> without the bogus {{Class-Path}} element in it's {{META-INF/MANIFEST.MF}} or
> a new release should be published that corrects this defect.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
[jira] [Created] (KAFKA-16280) Expose method to determine Metric Measurability
Apoorv Mittal created KAFKA-16280: - Summary: Expose method to determine Metric Measurability Key: KAFKA-16280 URL: https://issues.apache.org/jira/browse/KAFKA-16280 Project: Kafka Issue Type: Bug Components: metrics Affects Versions: 3.8.0 Reporter: Apoorv Mittal Assignee: Apoorv Mittal Fix For: 3.8.0 The Jira is to track the development of KIP-1019: [https://cwiki.apache.org/confluence/display/KAFKA/KIP-1019%3A+Expose+method+to+determine+Metric+Measurability] -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (KAFKA-15772) Flaky test TransactionsWithTieredStoreTest
[
https://issues.apache.org/jira/browse/KAFKA-15772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812485#comment-17812485
]
Apoorv Mittal commented on KAFKA-15772:
---
Failure of test: `testAbortTransactionTimeout` in
`TransactionsWithTieredStoreTest` class
https://ci-builds.apache.org/blue/organizations/jenkins/Kafka%2Fkafka-pr/detail/PR-15251/7/tests
{code:java}
Errororg.apache.kafka.common.errors.TimeoutException: Timeout expired after
3000ms while awaiting
InitProducerIdStacktraceorg.apache.kafka.common.errors.TimeoutException:
Timeout expired after 3000ms while awaiting InitProducerIdStandard
Output[2024-01-30 16:29:01,250] INFO [LocalTieredStorage Id=0] Creating
directory:
[/tmp/kafka-remote-tier-transactionswithtieredstoretest11967450412731752897/kafka-tiered-storage]
(org.apache.kafka.server.log.remote.storage.LocalTieredStorage:289)[2024-01-30
16:29:01,250] INFO [LocalTieredStorage Id=0] Created local tiered storage
manager [0]:[kafka-tiered-storage]
(org.apache.kafka.server.log.remote.storage.LocalTieredStorage:301)[2024-01-30
16:29:01,251] INFO Started configuring topic-based RLMM with configs:
{remote.log.metadata.topic.replication.factor=3,
remote.log.metadata.topic.num.partitions=3,
remote.log.metadata.common.client.bootstrap.servers=localhost:40061,
broker.id=0, remote.log.metadata.initialization.retry.interval.ms=300,
remote.log.metadata.common.client.security.protocol=PLAINTEXT,
cluster.id=z_bOu1YoRbKNNIThjztsdA, log.dir=/tmp/kafka-6827936654389854503}
(org.apache.kafka.server.log.remote.metadata.storage.TopicBasedRemoteLogMetadataManager:358)[2024-01-30
16:29:01,251] INFO Successfully configured topic-based RLMM with config:
TopicBasedRemoteLogMetadataManagerConfig{clientIdPrefix='__remote_log_metadata_client_0',
metadataTopicPartitionsCount=3, consumeWaitMs=12,
metadataTopicRetentionMs=-1, metadataTopicReplicationFactor=3,
initializationRetryMaxTimeoutMs=12, initializationRetryIntervalMs=300,
commonProps={security.protocol=PLAINTEXT, bootstrap.servers=localhost:40061},
consumerProps={security.protocol=PLAINTEXT,
key.deserializer=org.apache.kafka.common.serialization.ByteArrayDeserializer,
value.deserializer=org.apache.kafka.common.serialization.ByteArrayDeserializer,
enable.auto.commit=false, bootstrap.servers=localhost:40061,
exclude.internal.topics=false, auto.offset.reset=earliest,
client.id=__remote_log_metadata_client_0_consumer},
producerProps={security.protocol=PLAINTEXT, enable.idempotence=true,
value.serializer=org.apache.kafka.common.serialization.ByteArraySerializer,
acks=all, bootstrap.servers=localhost:40061,
key.serializer=org.apache.kafka.common.serialization.ByteArraySerializer,
client.id=__remote_log_metadata_client_0_producer}}
(org.apache.kafka.server.log.remote.metadata.storage.TopicBasedRemoteLogMetadataManager:364)[2024-01-30
16:29:01,252] INFO Initializing topic-based RLMM resources
(org.apache.kafka.server.log.remote.metadata.storage.TopicBasedRemoteLogMetadataManager:377)[2024-01-30
16:29:01,363] INFO Topic __remote_log_metadata does not exist. Error: This
server does not host this topic-partition.
(org.apache.kafka.server.log.remote.metadata.storage.TopicBasedRemoteLogMetadataManager:466)[2024-01-30
16:29:01,366] ERROR Encountered error while creating __remote_log_metadata
topic.
(org.apache.kafka.server.log.remote.metadata.storage.TopicBasedRemoteLogMetadataManager:528)java.util.concurrent.ExecutionException:
org.apache.kafka.common.errors.InvalidReplicationFactorException: Replication
factor: 3 larger than available brokers: 1. at
java.base/java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396)
at
java.base/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2073)
at
org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:165)
at
org.apache.kafka.server.log.remote.metadata.storage.TopicBasedRemoteLogMetadataManager.createTopic(TopicBasedRemoteLogMetadataManager.java:509)
at
org.apache.kafka.server.log.remote.metadata.storage.TopicBasedRemoteLogMetadataManager.initializeResources(TopicBasedRemoteLogMetadataManager.java:396)
at java.base/java.lang.Thread.run(Thread.java:833)Caused by:
org.apache.kafka.common.errors.InvalidReplicationFactorException: Replication
factor: 3 larger than available brokers: 1.[2024-01-30 16:29:01,366] INFO Sleep
for 300 ms before it is retried again.
(org.apache.kafka.server.log.remote.metadata.storage.TopicBasedRemoteLogMetadataManager:401)[2024-01-30
16:29:01,538] WARN [LocalTieredStorage Id=1] Remote storage with ID
[/tmp/kafka-remote-tier-transactionswithtieredstoretest11967450412731752897]
already exists on the file system. Any data already in the remote storage will
not be deleted and may result in an inconsistent state and/or provide stale
data.
[jira] [Resolved] (KAFKA-15683) Delete subscription from metadata when all configs are deleted
[ https://issues.apache.org/jira/browse/KAFKA-15683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-15683. --- Resolution: Not A Problem Closing ticket as this is not required, it works as per the default behaviour of kafka-configs.sh. Moreover ClientMetricsManager deletes the in-memory subscription/client resources once all properties for respective resource are removed. This is not needed. > Delete subscription from metadata when all configs are deleted > -- > > Key: KAFKA-15683 > URL: https://issues.apache.org/jira/browse/KAFKA-15683 > Project: Kafka > Issue Type: Sub-task >Reporter: Apoorv Mittal >Assignee: Apoorv Mittal >Priority: Major > > As of now the kafka-configs.sh do not differentiate on non-existent and blank > metrics subscription. Add support to differentiate in 2 scenarios and also > delete the subscription if all configs are delete for respective > subscription. -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (KAFKA-16187) Flaky test: testTopicPatternArg - org.apache.kafka.tools.GetOffsetShellTest
Apoorv Mittal created KAFKA-16187:
-
Summary: Flaky test: testTopicPatternArg -
org.apache.kafka.tools.GetOffsetShellTest
Key: KAFKA-16187
URL: https://issues.apache.org/jira/browse/KAFKA-16187
Project: Kafka
Issue Type: Bug
Reporter: Apoorv Mittal
[https://ci-builds.apache.org/blue/organizations/jenkins/Kafka%2Fkafka-pr/detail/PR-15234/8/tests/]
{code:java}
Errororg.opentest4j.AssertionFailedError: expected:
<[org.apache.kafka.tools.GetOffsetShellTest$Row@c6f09cc2,
org.apache.kafka.tools.GetOffsetShellTest$Row@c6f0a084,
org.apache.kafka.tools.GetOffsetShellTest$Row@c6f0a0a3,
org.apache.kafka.tools.GetOffsetShellTest$Row@c6f0a446,
org.apache.kafka.tools.GetOffsetShellTest$Row@c6f0a465,
org.apache.kafka.tools.GetOffsetShellTest$Row@c6f0a484,
org.apache.kafka.tools.GetOffsetShellTest$Row@c6f0a808,
org.apache.kafka.tools.GetOffsetShellTest$Row@c6f0a827,
org.apache.kafka.tools.GetOffsetShellTest$Row@c6f0a846,
org.apache.kafka.tools.GetOffsetShellTest$Row@c6f0a865]> but was:
<[org.apache.kafka.tools.GetOffsetShellTest$Row@c6f09cc2,
org.apache.kafka.tools.GetOffsetShellTest$Row@c6f0a084,
org.apache.kafka.tools.GetOffsetShellTest$Row@c6f0a446,
org.apache.kafka.tools.GetOffsetShellTest$Row@c6f0a808]>Stacktraceorg.opentest4j.AssertionFailedError:
expected: <[org.apache.kafka.tools.GetOffsetShellTest$Row@c6f09cc2,
org.apache.kafka.tools.GetOffsetShellTest$Row@c6f0a084,
org.apache.kafka.tools.GetOffsetShellTest$Row@c6f0a0a3,
org.apache.kafka.tools.GetOffsetShellTest$Row@c6f0a446,
org.apache.kafka.tools.GetOffsetShellTest$Row@c6f0a465,
org.apache.kafka.tools.GetOffsetShellTest$Row@c6f0a484,
org.apache.kafka.tools.GetOffsetShellTest$Row@c6f0a808,
org.apache.kafka.tools.GetOffsetShellTest$Row@c6f0a827,
org.apache.kafka.tools.GetOffsetShellTest$Row@c6f0a846,
org.apache.kafka.tools.GetOffsetShellTest$Row@c6f0a865]> but was:
<[org.apache.kafka.tools.GetOffsetShellTest$Row@c6f09cc2,
org.apache.kafka.tools.GetOffsetShellTest$Row@c6f0a084,
org.apache.kafka.tools.GetOffsetShellTest$Row@c6f0a446,
org.apache.kafka.tools.GetOffsetShellTest$Row@c6f0a808]> at
app//org.junit.jupiter.api.AssertionFailureBuilder.build(AssertionFailureBuilder.java:151)
at
app//org.junit.jupiter.api.AssertionFailureBuilder.buildAndThrow(AssertionFailureBuilder.java:132)
at
app//org.junit.jupiter.api.AssertEquals.failNotEqual(AssertEquals.java:197) at
app//org.junit.jupiter.api.AssertEquals.assertEquals(AssertEquals.java:182) at
app//org.junit.jupiter.api.AssertEquals.assertEquals(AssertEquals.java:177) at
app//org.junit.jupiter.api.Assertions.assertEquals(Assertions.java:1141) at
app//org.apache.kafka.tools.GetOffsetShellTest.testTopicPatternArg(GetOffsetShellTest.java:154)
at
java.base@21.0.1/jdk.internal.reflect.DirectMethodHandleAccessor.invoke(DirectMethodHandleAccessor.java:103)
at java.base@21.0.1/java.lang.reflect.Method.invoke(Method.java:580)at
app//org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:728)
at
app//org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60)
at
app//org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)
at
app//org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:156)
at
app//org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestableMethod(TimeoutExtension.java:147)
at
app//org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestTemplateMethod(TimeoutExtension.java:94)
at
app//org.junit.jupiter.engine.execution.InterceptingExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(InterceptingExecutableInvoker.java:103)
at
app//org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.lambda$invoke$0(InterceptingExecutableInvoker.java:93)
at
app//org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)
at
app//org.junit.jupiter.engine.execution.InvocationInterceptorChain.proceed(InvocationInterceptorChain.java:64)
at
app//org.junit.jupiter.engine.execution.InvocationInterceptorChain.chainAndInvoke(InvocationInterceptorChain.java:45)
at
app//org.junit.jupiter.engine.execution.InvocationInterceptorChain.invoke(InvocationInterceptorChain.java:37)
at
app//org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.invoke(InterceptingExecutableInvoker.java:92)
at
app//org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.invoke(InterceptingExecutableInvoker.java:86)
at
app//org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.lambda$invokeTestMethod$7(TestMethodTestDescriptor.java:218)
at
[jira] [Created] (KAFKA-16186) Implement broker metrics for client telemetry usage
Apoorv Mittal created KAFKA-16186: - Summary: Implement broker metrics for client telemetry usage Key: KAFKA-16186 URL: https://issues.apache.org/jira/browse/KAFKA-16186 Project: Kafka Issue Type: Sub-task Reporter: Apoorv Mittal Assignee: Apoorv Mittal The KIP-714 lists new metrics for broker which records the usage of client telemetry instances and plugin. Implement broker metrics as defined in the KIP-714. -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (KAFKA-16176) Flaky test: testSendToPartitionWithFollowerShutdownShouldNotTimeout – kafka.api.PlaintextProducerSendTest
Apoorv Mittal created KAFKA-16176:
-
Summary: Flaky test:
testSendToPartitionWithFollowerShutdownShouldNotTimeout –
kafka.api.PlaintextProducerSendTest
Key: KAFKA-16176
URL: https://issues.apache.org/jira/browse/KAFKA-16176
Project: Kafka
Issue Type: Bug
Reporter: Apoorv Mittal
[https://ci-builds.apache.org/blue/organizations/jenkins/Kafka%2Fkafka-pr/detail/PR-15190/3/tests/]
{code:java}
Errororg.opentest4j.AssertionFailedError: Consumed 0 records before timeout
instead of the expected 100
recordsStacktraceorg.opentest4j.AssertionFailedError: Consumed 0 records before
timeout instead of the expected 100 records at
app//org.junit.jupiter.api.AssertionUtils.fail(AssertionUtils.java:38) at
app//org.junit.jupiter.api.Assertions.fail(Assertions.java:134) at
app//kafka.utils.TestUtils$.pollUntilAtLeastNumRecords(TestUtils.scala:1142) at
app//kafka.utils.TestUtils$.consumeRecords(TestUtils.scala:1869) at
app//kafka.api.BaseProducerSendTest.testSendToPartitionWithFollowerShutdownShouldNotTimeout(BaseProducerSendTest.scala:398)
at
java.base@11.0.16.1/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native
Method) at
java.base@11.0.16.1/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
java.base@11.0.16.1/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.base@11.0.16.1/java.lang.reflect.Method.invoke(Method.java:566) at
app//org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:728)
at
app//org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60)
at
app//org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)
at
app//org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:156)
at
app//org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestableMethod(TimeoutExtension.java:147)
at
app//org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestTemplateMethod(TimeoutExtension.java:94)
{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
[jira] [Created] (KAFKA-16177) Flaky test: testBatchSizeZeroNoPartitionNoRecordKey – kafka.api.PlaintextProducerSendTest
Apoorv Mittal created KAFKA-16177:
-
Summary: Flaky test: testBatchSizeZeroNoPartitionNoRecordKey –
kafka.api.PlaintextProducerSendTest
Key: KAFKA-16177
URL: https://issues.apache.org/jira/browse/KAFKA-16177
Project: Kafka
Issue Type: Bug
Reporter: Apoorv Mittal
[https://ci-builds.apache.org/blue/organizations/jenkins/Kafka%2Fkafka-pr/detail/PR-15190/3/tests/]
{code:java}
Errorjava.lang.RuntimeException: Received a fatal error while waiting for the
controller to acknowledge that we are caught
upStacktracejava.lang.RuntimeException: Received a fatal error while waiting
for the controller to acknowledge that we are caught up at
org.apache.kafka.server.util.FutureUtils.waitWithLogging(FutureUtils.java:68)
at kafka.server.BrokerServer.startup(BrokerServer.scala:473)at
kafka.integration.KafkaServerTestHarness.$anonfun$createBrokers$1(KafkaServerTestHarness.scala:355)
at
kafka.integration.KafkaServerTestHarness.$anonfun$createBrokers$1$adapted(KafkaServerTestHarness.scala:351)
at scala.collection.immutable.Vector.foreach(Vector.scala:2124) at
kafka.integration.KafkaServerTestHarness.createBrokers(KafkaServerTestHarness.scala:351)
at
kafka.integration.KafkaServerTestHarness.setUp(KafkaServerTestHarness.scala:120)
at kafka.api.BaseProducerSendTest.setUp(BaseProducerSendTest.scala:70) at
jdk.internal.reflect.GeneratedMethodAccessor40.invoke(Unknown Source)at
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.base/java.lang.reflect.Method.invoke(Method.java:566) at
org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:728)
at
org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60)
at
org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)
at
org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:156)
at
org.junit.jupiter.engine.extension.TimeoutExtension.interceptLifecycleMethod(TimeoutExtension.java:128)
{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
[jira] [Created] (KAFKA-16175) Flaky test: testAsynchronousAuthorizerAclUpdatesDontBlockRequestThreads – kafka.api.SslAdminIntegrationTest
Apoorv Mittal created KAFKA-16175:
-
Summary: Flaky test:
testAsynchronousAuthorizerAclUpdatesDontBlockRequestThreads –
kafka.api.SslAdminIntegrationTest
Key: KAFKA-16175
URL: https://issues.apache.org/jira/browse/KAFKA-16175
Project: Kafka
Issue Type: Bug
Reporter: Apoorv Mittal
[https://ci-builds.apache.org/blue/organizations/jenkins/Kafka%2Fkafka-pr/detail/PR-15190/3/tests/]
{code:java}
Errororg.opentest4j.AssertionFailedError: expected: <24> but was:
<32>Stacktraceorg.opentest4j.AssertionFailedError: expected: <24> but was: <32>
at
app//org.junit.jupiter.api.AssertionFailureBuilder.build(AssertionFailureBuilder.java:151)
at
app//org.junit.jupiter.api.AssertionFailureBuilder.buildAndThrow(AssertionFailureBuilder.java:132)
at
app//org.junit.jupiter.api.AssertEquals.failNotEqual(AssertEquals.java:197) at
app//org.junit.jupiter.api.AssertEquals.assertEquals(AssertEquals.java:150) at
app//org.junit.jupiter.api.AssertEquals.assertEquals(AssertEquals.java:145) at
app//org.junit.jupiter.api.Assertions.assertEquals(Assertions.java:527) at
app//kafka.api.SslAdminIntegrationTest.blockedRequestThreads(SslAdminIntegrationTest.scala:243)
at
app//kafka.api.SslAdminIntegrationTest.$anonfun$waitForNoBlockedRequestThreads$1(SslAdminIntegrationTest.scala:250)
at
app//kafka.api.SslAdminIntegrationTest.waitForNoBlockedRequestThreads(SslAdminIntegrationTest.scala:250)
at
app//kafka.api.SslAdminIntegrationTest.testAsynchronousAuthorizerAclUpdatesDontBlockRequestThreads(SslAdminIntegrationTest.scala:176)
at
java.base@11.0.16.1/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native
Method) at
java.base@11.0.16.1/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
java.base@11.0.16.1/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.base@11.0.16.1/java.lang.reflect.Method.invoke(Method.java:566) at
app//org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:728){code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
[jira] [Created] (KAFKA-16174) Flaky test: testDescribeQuorumStatusSuccessful – org.apache.kafka.tools.MetadataQuorumCommandTest
Apoorv Mittal created KAFKA-16174:
-
Summary: Flaky test: testDescribeQuorumStatusSuccessful –
org.apache.kafka.tools.MetadataQuorumCommandTest
Key: KAFKA-16174
URL: https://issues.apache.org/jira/browse/KAFKA-16174
Project: Kafka
Issue Type: Bug
Reporter: Apoorv Mittal
[https://ci-builds.apache.org/blue/organizations/jenkins/Kafka%2Fkafka-pr/detail/PR-15190/3/tests/]
{code:java}
Errorjava.util.concurrent.ExecutionException: java.lang.RuntimeException:
Received a fatal error while waiting for the controller to acknowledge that we
are caught upStacktracejava.util.concurrent.ExecutionException:
java.lang.RuntimeException: Received a fatal error while waiting for the
controller to acknowledge that we are caught up at
java.base/java.util.concurrent.FutureTask.report(FutureTask.java:122)at
java.base/java.util.concurrent.FutureTask.get(FutureTask.java:191) at
kafka.testkit.KafkaClusterTestKit.startup(KafkaClusterTestKit.java:421) at
kafka.test.junit.RaftClusterInvocationContext.lambda$getAdditionalExtensions$5(RaftClusterInvocationContext.java:116)
at
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.lambda$invokeBeforeTestExecutionCallbacks$5(TestMethodTestDescriptor.java:192)
at
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.lambda$invokeBeforeMethodsOrCallbacksUntilExceptionOccurs$6(TestMethodTestDescriptor.java:203)
at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.invokeBeforeMethodsOrCallbacksUntilExceptionOccurs(TestMethodTestDescriptor.java:203)
at
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.invokeBeforeTestExecutionCallbacks(TestMethodTestDescriptor.java:191)
at
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:137)
at
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:69)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:151)
at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
at
org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
at
org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.submit(SameThreadHierarchicalTestExecutorService.java:35)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask$DefaultDynamicTestExecutor.execute(NodeTestTask.java:226)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask$DefaultDynamicTestExecutor.execute(NodeTestTask.java:204)
{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
[jira] [Created] (KAFKA-16173) Flaky test: testTimeoutMetrics – org.apache.kafka.controller.QuorumControllerMetricsIntegrationTest
Apoorv Mittal created KAFKA-16173:
-
Summary: Flaky test: testTimeoutMetrics –
org.apache.kafka.controller.QuorumControllerMetricsIntegrationTest
Key: KAFKA-16173
URL: https://issues.apache.org/jira/browse/KAFKA-16173
Project: Kafka
Issue Type: Bug
Reporter: Apoorv Mittal
[https://ci-builds.apache.org/blue/organizations/jenkins/Kafka%2Fkafka-pr/detail/PR-15190/3/tests/]
{code:java}
Errororg.apache.kafka.server.fault.FaultHandlerException: fatalFaultHandler:
exception while renouncing leadership: Attempt to resign from epoch 1 which is
larger than the current epoch
0Stacktraceorg.apache.kafka.server.fault.FaultHandlerException:
fatalFaultHandler: exception while renouncing leadership: Attempt to resign
from epoch 1 which is larger than the current epoch 0 at
app//org.apache.kafka.metalog.LocalLogManager.resign(LocalLogManager.java:808)
at
app//org.apache.kafka.controller.QuorumController.renounce(QuorumController.java:1270)
at
app//org.apache.kafka.controller.QuorumController.handleEventException(QuorumController.java:547)
at
app//org.apache.kafka.controller.QuorumController.access$800(QuorumController.java:179)
at
app//org.apache.kafka.controller.QuorumController$ControllerWriteEvent.complete(QuorumController.java:881)
at
app//org.apache.kafka.controller.QuorumController$ControllerWriteEvent.handleException(QuorumController.java:871)
at
app//org.apache.kafka.queue.KafkaEventQueue$EventContext.completeWithException(KafkaEventQueue.java:148)
at
app//org.apache.kafka.queue.KafkaEventQueue$EventContext.run(KafkaEventQueue.java:137)
at
app//org.apache.kafka.queue.KafkaEventQueue$EventHandler.handleEvents(KafkaEventQueue.java:210)
at
app//org.apache.kafka.queue.KafkaEventQueue$EventHandler.run(KafkaEventQueue.java:181)
at java.base@21.0.1/java.lang.Thread.run(Thread.java:1583)Caused by:
java.lang.IllegalArgumentException: Attempt to resign from epoch 1 which is
larger than the current epoch 0... 11 more {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
[jira] [Created] (KAFKA-16172) Flaky test: testProducerConsumerOverrideLowerQuota – kafka.api.UserQuotaTest
Apoorv Mittal created KAFKA-16172:
-
Summary: Flaky test: testProducerConsumerOverrideLowerQuota –
kafka.api.UserQuotaTest
Key: KAFKA-16172
URL: https://issues.apache.org/jira/browse/KAFKA-16172
Project: Kafka
Issue Type: Bug
Reporter: Apoorv Mittal
https://ci-builds.apache.org/blue/organizations/jenkins/Kafka%2Fkafka-pr/detail/PR-15190/3/tests/
{code:java}
Errororg.opentest4j.AssertionFailedError: Client with id=QuotasTestProducer-1
should have been throttled, 0.0 ==> expected: but was:
Stacktraceorg.opentest4j.AssertionFailedError: Client with
id=QuotasTestProducer-1 should have been throttled, 0.0 ==> expected:
but was: at
app//org.junit.jupiter.api.AssertionFailureBuilder.build(AssertionFailureBuilder.java:151)
at
app//org.junit.jupiter.api.AssertionFailureBuilder.buildAndThrow(AssertionFailureBuilder.java:132)
at app//org.junit.jupiter.api.AssertTrue.failNotTrue(AssertTrue.java:63)
at app//org.junit.jupiter.api.AssertTrue.assertTrue(AssertTrue.java:36) at
app//org.junit.jupiter.api.Assertions.assertTrue(Assertions.java:210)at
app//kafka.api.QuotaTestClients.verifyThrottleTimeRequestChannelMetric(BaseQuotaTest.scala:261)
at
app//kafka.api.QuotaTestClients.verifyProduceThrottle(BaseQuotaTest.scala:270)
at
app//kafka.api.BaseQuotaTest.testProducerConsumerOverrideLowerQuota(BaseQuotaTest.scala:133)
at
java.base@21.0.1/jdk.internal.reflect.DirectMethodHandleAccessor.invoke(DirectMethodHandleAccessor.java:103)
at java.base@21.0.1/java.lang.reflect.Method.invoke(Method.java:580)at
app//org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:728)
at
app//org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60)
at
app//org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)
at
app//org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:156)
at
app//org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestableMethod(TimeoutExtension.java:147)
at
app//org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestTemplateMethod(TimeoutExtension.java:94)
at
app//org.junit.jupiter.engine.execution.InterceptingExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(InterceptingExecutableInvoker.java:103)
at
app//org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.lambda$invoke$0(InterceptingExecutableInvoker.java:93)
at
app//org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)
at
app//org.junit.jupiter.engine.execution.InvocationInterceptorChain.proceed(InvocationInterceptorChain.java:64)
at
app//org.junit.jupiter.engine.execution.InvocationInterceptorChain.chainAndInvoke(InvocationInterceptorChain.java:45)
at
app//org.junit.jupiter.engine.execution.InvocationInterceptorChain.invoke(InvocationInterceptorChain.java:37)
at
app//org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.invoke(InterceptingExecutableInvoker.java:92)
at
app//org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.invoke(InterceptingExecutableInvoker.java:86)
at
app//org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.lambda$invokeTestMethod$7(TestMethodTestDescriptor.java:218)
at
app//org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at
app//org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.invokeTestMethod(TestMethodTestDescriptor.java:214)
{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
[jira] [Resolved] (KAFKA-15807) Add support for compression/decompression of metrics
[ https://issues.apache.org/jira/browse/KAFKA-15807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-15807. --- Resolution: Done > Add support for compression/decompression of metrics > > > Key: KAFKA-15807 > URL: https://issues.apache.org/jira/browse/KAFKA-15807 > Project: Kafka > Issue Type: Sub-task >Reporter: Apoorv Mittal >Assignee: Apoorv Mittal >Priority: Major > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (KAFKA-15863) Handle push telemetry throttling with quota manager
[
https://issues.apache.org/jira/browse/KAFKA-15863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17807315#comment-17807315
]
Apoorv Mittal commented on KAFKA-15863:
---
[~junrao] I looked at the code, suggestion of yours and KIP-714, it seems to me
that KIP wants 2 throttle checks i.e. 1 at request level with generic
throttling and 2 specific to time interval defined for push. I don't think we
need to have another quota defined specific to client telemetry as the intent
is to throttle the rogue client which we are anyways handling by default client
request quota. I have tested the behaviour by setting low value of client
request quota for `producer-1` client id, and can successfully see throttling
happening for push telemetry requests. I am marking the ticket as resolved,
please let me know if I am missing something.
cc: [~schofielaj].
{code:java}
[APM] Throttle check for : producer-1, time: 100.0890606
[APM] Checking quota for metric MetricName [name=request-time, group=Request,
description=Tracking request-time per user/client-id, tags={user=,
client-id=producer-1}] with value 10.00890606
[APM] Non-TokenBucket quota for metric MetricName [name=request-time,
group=Request, description=Tracking request-time per user/client-id,
tags={user=, client-id=producer-1}] with value 10.00890606
[APM] Quota.acceptable: 10.00890606 1.0 true
[2024-01-16 15:42:39,350] INFO Quota violated for sensor (Request-:producer-1).
Delay time: (1000) (kafka.server.ClientRequestQuotaManager)
[2024-01-16 15:42:39,350] INFO Channel throttled for sensor
(Request-:producer-1). Delay time: (1000)
(kafka.server.ClientRequestQuotaManager)
[APM] Throttling response for client producer-1 on broker is 1000ms, response
is PushTelemetryResponseData(throttleTimeMs=1000, errorCode=0){code}
> Handle push telemetry throttling with quota manager
> ---
>
> Key: KAFKA-15863
> URL: https://issues.apache.org/jira/browse/KAFKA-15863
> Project: Kafka
> Issue Type: Sub-task
>Reporter: Apoorv Mittal
>Assignee: Apoorv Mittal
>Priority: Major
>
> Details: https://github.com/apache/kafka/pull/14699#discussion_r1399714279
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
[jira] [Resolved] (KAFKA-15863) Handle push telemetry throttling with quota manager
[ https://issues.apache.org/jira/browse/KAFKA-15863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-15863. --- Resolution: Not A Problem > Handle push telemetry throttling with quota manager > --- > > Key: KAFKA-15863 > URL: https://issues.apache.org/jira/browse/KAFKA-15863 > Project: Kafka > Issue Type: Sub-task >Reporter: Apoorv Mittal >Assignee: Apoorv Mittal >Priority: Major > > Details: https://github.com/apache/kafka/pull/14699#discussion_r1399714279 -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Resolved] (KAFKA-15952) Create public doc for telemetry state transition
[ https://issues.apache.org/jira/browse/KAFKA-15952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-15952. --- Resolution: Won't Do > Create public doc for telemetry state transition > > > Key: KAFKA-15952 > URL: https://issues.apache.org/jira/browse/KAFKA-15952 > Project: Kafka > Issue Type: Sub-task >Reporter: Apoorv Mittal >Assignee: Apoorv Mittal >Priority: Major > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (KAFKA-15952) Create public doc for telemetry state transition
[ https://issues.apache.org/jira/browse/KAFKA-15952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17806414#comment-17806414 ] Apoorv Mittal commented on KAFKA-15952: --- [~pnee] I think I misunderstood the feedback earlier and created the Jira to document the state transition but seems it's not needed as per the conversation on the thread: [https://github.com/apache/kafka/pull/14724#discussion_r1412484071.] The state transitions have been documented in the code here: [https://github.com/apache/kafka/blob/378a01999ef3f80910f506d8c419e825d5a90a97/clients/src/main/java/org/apache/kafka/common/telemetry/ClientTelemetryState.java#L70.] I am closing the ticket as won't do. > Create public doc for telemetry state transition > > > Key: KAFKA-15952 > URL: https://issues.apache.org/jira/browse/KAFKA-15952 > Project: Kafka > Issue Type: Sub-task >Reporter: Apoorv Mittal >Assignee: Apoorv Mittal >Priority: Major > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (KAFKA-15958) Add tests to validate telemetry requests with different version
[ https://issues.apache.org/jira/browse/KAFKA-15958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17806412#comment-17806412 ] Apoorv Mittal commented on KAFKA-15958: --- [~pnee] I have looked into the suggestion to use Parametrized Test to check different versions but I don't see any benefit yet as the only version supported is 0. The suggestion pointed to `HeartbeatRequestManagerTest` which also just iterates on just 0 version occurrence yet and that's the same behaviour is for telemetry requests test. If the suggestion was to add this parametrized test so it could be the future support when versions are incremented in telemetry requests then I think we shall handle some checks according to incremented version and they would be known once version is incremented, for example in `JoinGroupResponseTest.java`, etc. Again I don't see any benefit making the tests for telemetry requests Parametrized currently. I am closing this ticket, please let me know if you think otherwise then we can discuss further. > Add tests to validate telemetry requests with different version > --- > > Key: KAFKA-15958 > URL: https://issues.apache.org/jira/browse/KAFKA-15958 > Project: Kafka > Issue Type: Sub-task >Reporter: Apoorv Mittal >Assignee: Apoorv Mittal >Priority: Major > > Details: https://github.com/apache/kafka/pull/14724#discussion_r1412530561 -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Resolved] (KAFKA-15958) Add tests to validate telemetry requests with different version
[ https://issues.apache.org/jira/browse/KAFKA-15958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-15958. --- Resolution: Won't Do > Add tests to validate telemetry requests with different version > --- > > Key: KAFKA-15958 > URL: https://issues.apache.org/jira/browse/KAFKA-15958 > Project: Kafka > Issue Type: Sub-task >Reporter: Apoorv Mittal >Assignee: Apoorv Mittal >Priority: Major > > Details: https://github.com/apache/kafka/pull/14724#discussion_r1412530561 -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Resolved] (KAFKA-15972) Add support to exclude labels in client telemetry
[ https://issues.apache.org/jira/browse/KAFKA-15972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-15972. --- Resolution: Done > Add support to exclude labels in client telemetry > - > > Key: KAFKA-15972 > URL: https://issues.apache.org/jira/browse/KAFKA-15972 > Project: Kafka > Issue Type: Sub-task >Reporter: Apoorv Mittal >Assignee: Apoorv Mittal >Priority: Major > > Some of the labels/tags which are present in metric should be skipped while > collecting telemetry as data might already be known to broker hence, we > should minimize the data transfer. One of such labels is client_id which is > already present in RequestContext hence broker can append that label prior > emitting metrics to telemetry backend. -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Resolved] (KAFKA-15877) Support change of temporality in Java client
[ https://issues.apache.org/jira/browse/KAFKA-15877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-15877. --- Resolution: Done > Support change of temporality in Java client > - > > Key: KAFKA-15877 > URL: https://issues.apache.org/jira/browse/KAFKA-15877 > Project: Kafka > Issue Type: Sub-task >Reporter: Apoorv Mittal >Assignee: Apoorv Mittal >Priority: Major > > Details: https://github.com/apache/kafka/pull/14620#discussion_r1401554867 -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (KAFKA-15877) Support change of temporality in Java client
[ https://issues.apache.org/jira/browse/KAFKA-15877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17793896#comment-17793896 ] Apoorv Mittal commented on KAFKA-15877: --- Changes were committed as part of PR: https://github.com/apache/kafka/pull/14620 https://github.com/apache/kafka/pull/14620#issuecomment-1826401674 > Support change of temporality in Java client > - > > Key: KAFKA-15877 > URL: https://issues.apache.org/jira/browse/KAFKA-15877 > Project: Kafka > Issue Type: Sub-task >Reporter: Apoorv Mittal >Assignee: Apoorv Mittal >Priority: Major > > Details: https://github.com/apache/kafka/pull/14620#discussion_r1401554867 -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (KAFKA-15972) Add support to exclude labels in client telemetry
Apoorv Mittal created KAFKA-15972: - Summary: Add support to exclude labels in client telemetry Key: KAFKA-15972 URL: https://issues.apache.org/jira/browse/KAFKA-15972 Project: Kafka Issue Type: Sub-task Reporter: Apoorv Mittal Assignee: Apoorv Mittal Some of the labels/tags which are present in metric should be skipped while collecting telemetry as data might already be known to broker hence, we should minimize the data transfer. One of such labels is client_id which is already present in RequestContext hence broker can append that label prior emitting metrics to telemetry backend. -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (KAFKA-15965) Test failure: org.apache.kafka.common.requests.BrokerRegistrationRequestTest
Apoorv Mittal created KAFKA-15965:
-
Summary: Test failure:
org.apache.kafka.common.requests.BrokerRegistrationRequestTest
Key: KAFKA-15965
URL: https://issues.apache.org/jira/browse/KAFKA-15965
Project: Kafka
Issue Type: Bug
Reporter: Apoorv Mittal
2 tests for versions 0 and 1 fails consistently.
Build:
https://ci-builds.apache.org/blue/organizations/jenkins/Kafka%2Fkafka-pr/detail/PR-14767/15/tests/
{code:java}
org.opentest4j.AssertionFailedError: BrokerRegistrationRequestData(brokerId=0,
clusterId='test', incarnationId=Xil73H5bSZ2vYTWUVlf07Q, listeners=[],
features=[], rack='a', isMigratingZkBroker=false, logDirs=[],
previousBrokerEpoch=1) ==> expected: <-1> but was:
<1>Stacktraceorg.opentest4j.AssertionFailedError:
BrokerRegistrationRequestData(brokerId=0, clusterId='test',
incarnationId=Xil73H5bSZ2vYTWUVlf07Q, listeners=[], features=[], rack='a',
isMigratingZkBroker=false, logDirs=[], previousBrokerEpoch=1) ==> expected:
<-1> but was: <1>at
app//org.junit.jupiter.api.AssertionFailureBuilder.build(AssertionFailureBuilder.java:151)
at
app//org.junit.jupiter.api.AssertionFailureBuilder.buildAndThrow(AssertionFailureBuilder.java:132)
at
app//org.junit.jupiter.api.AssertEquals.failNotEqual(AssertEquals.java:197) at
app//org.junit.jupiter.api.AssertEquals.assertEquals(AssertEquals.java:166) at
app//org.junit.jupiter.api.Assertions.assertEquals(Assertions.java:660) at
app//org.apache.kafka.common.requests.BrokerRegistrationRequestTest.testBasicBuild(BrokerRegistrationRequestTest.java:57)
at
java.base@17.0.7/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native
Method)at
java.base@17.0.7/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
at
java.base@17.0.7/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.base@17.0.7/java.lang.reflect.Method.invoke(Method.java:568)
at
app//org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:728)
at
app//org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60)
at
app//org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)
at
app//org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:156)
at
app//org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestableMethod(TimeoutExtension.java:147)
at
app//org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestTemplateMethod(TimeoutExtension.java:94)
at
app//org.junit.jupiter.engine.execution.InterceptingExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(InterceptingExecutableInvoker.java:103)
at
app//org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.lambda$invoke$0(InterceptingExecutableInvoker.java:93)
at
app//org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)
at
app//org.junit.jupiter.engine.execution.InvocationInterceptorChain.proceed(InvocationInterceptorChain.java:64)
at
app//org.junit.jupiter.engine.execution.InvocationInterceptorChain.chainAndInvoke(InvocationInterceptorChain.java:45)
{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
[jira] [Created] (KAFKA-15964) Flaky test: testHighAvailabilityTaskAssignorLargeNumConsumers – org.apache.kafka.streams.processor.internals.StreamsAssignmentScaleTest
Apoorv Mittal created KAFKA-15964:
-
Summary: Flaky test:
testHighAvailabilityTaskAssignorLargeNumConsumers –
org.apache.kafka.streams.processor.internals.StreamsAssignmentScaleTest
Key: KAFKA-15964
URL: https://issues.apache.org/jira/browse/KAFKA-15964
Project: Kafka
Issue Type: Bug
Reporter: Apoorv Mittal
PR build:
[https://ci-builds.apache.org/blue/organizations/jenkins/Kafka%2Fkafka-pr/detail/PR-14767/15/tests/]
{code:java}
java.lang.AssertionError: The first assignment took too long to complete at
94250ms.Stacktracejava.lang.AssertionError: The first assignment took too long
to complete at 94250ms. at
org.apache.kafka.streams.processor.internals.StreamsAssignmentScaleTest.completeLargeAssignment(StreamsAssignmentScaleTest.java:220)
at
org.apache.kafka.streams.processor.internals.StreamsAssignmentScaleTest.testHighAvailabilityTaskAssignorLargeNumConsumers(StreamsAssignmentScaleTest.java:85)
at
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
at
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.base/java.lang.reflect.Method.invoke(Method.java:568) at
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
at
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at
org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
at
org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at
org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:299)
at
org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:293)
{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
[jira] [Created] (KAFKA-15963) Flaky test: testBrokerHeartbeatDuringMigration [3] 3.6-IV0 – org.apache.kafka.controller.QuorumControllerTest
Apoorv Mittal created KAFKA-15963:
-
Summary: Flaky test: testBrokerHeartbeatDuringMigration [3]
3.6-IV0 – org.apache.kafka.controller.QuorumControllerTest
Key: KAFKA-15963
URL: https://issues.apache.org/jira/browse/KAFKA-15963
Project: Kafka
Issue Type: Bug
Reporter: Apoorv Mittal
PR build:
[https://ci-builds.apache.org/blue/organizations/jenkins/Kafka%2Fkafka-pr/detail/PR-14767/15/tests/]
{code:java}
java.util.concurrent.ExecutionException:
org.apache.kafka.common.errors.NotControllerException: No controller appears to
be active.Stacktracejava.util.concurrent.ExecutionException:
org.apache.kafka.common.errors.NotControllerException: No controller appears to
be active.at
java.base/java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396)
at
java.base/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2073)
at
org.apache.kafka.controller.QuorumControllerTest.testBrokerHeartbeatDuringMigration(QuorumControllerTest.java:1725)
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native
Method) at
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
at
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.base/java.lang.reflect.Method.invoke(Method.java:568) at
org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:728)
at
org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60)
at
org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)
at
org.junit.jupiter.engine.extension.SameThreadTimeoutInvocation.proceed(SameThreadTimeoutInvocation.java:45)
at
org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:156)
at
org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestableMethod(TimeoutExtension.java:147)
at
org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestTemplateMethod(TimeoutExtension.java:94)
at
org.junit.jupiter.engine.execution.InterceptingExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(InterceptingExecutableInvoker.java:103)
at
org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.lambda$invoke$0(InterceptingExecutableInvoker.java:93)
{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
[jira] [Created] (KAFKA-15962) Flaky test: testAlterPartitionVersion2KeepWorkingWhenControllerDowngradeToPre28IBP() – kafka.controller.ControllerIntegrationTest
Apoorv Mittal created KAFKA-15962:
-
Summary: Flaky test:
testAlterPartitionVersion2KeepWorkingWhenControllerDowngradeToPre28IBP() –
kafka.controller.ControllerIntegrationTest
Key: KAFKA-15962
URL: https://issues.apache.org/jira/browse/KAFKA-15962
Project: Kafka
Issue Type: Bug
Reporter: Apoorv Mittal
PR build:
https://ci-builds.apache.org/blue/organizations/jenkins/Kafka%2Fkafka-pr/detail/PR-14767/15/tests/
{code:java}
java.util.NoSuchElementException: key not found:
0Stacktracejava.util.NoSuchElementException: key not found: 0 at
scala.collection.MapOps.default(Map.scala:274) at
scala.collection.MapOps.default$(Map.scala:273) at
scala.collection.AbstractMap.default(Map.scala:405) at
scala.collection.mutable.HashMap.apply(HashMap.scala:440)at
kafka.controller.ControllerIntegrationTest.testAlterPartitionVersion2KeepWorkingWhenControllerDowngradeToPre28IBP(ControllerIntegrationTest.scala:1031)
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native
Method) at
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
at
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.base/java.lang.reflect.Method.invoke(Method.java:568) at
org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:728)
at
org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60)
at
org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)
{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
[jira] [Created] (KAFKA-15961) Flaky test: testTopicIdPersistsThroughControllerRestart() – kafka.controller.ControllerIntegrationTest
Apoorv Mittal created KAFKA-15961:
-
Summary: Flaky test:
testTopicIdPersistsThroughControllerRestart() –
kafka.controller.ControllerIntegrationTest
Key: KAFKA-15961
URL: https://issues.apache.org/jira/browse/KAFKA-15961
Project: Kafka
Issue Type: Bug
Reporter: Apoorv Mittal
PR build:
[https://ci-builds.apache.org/blue/organizations/jenkins/Kafka%2Fkafka-pr/detail/PR-14767/15/tests/]
{code:java}
java.util.NoSuchElementException:
None.getStacktracejava.util.NoSuchElementException: None.get at
scala.None$.get(Option.scala:627)at scala.None$.get(Option.scala:626)at
kafka.controller.ControllerIntegrationTest.testTopicIdPersistsThroughControllerRestart(ControllerIntegrationTest.scala:1684)
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native
Method) at
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
at
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.base/java.lang.reflect.Method.invoke(Method.java:568) at
org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:728)
at
org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60)
at
org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)
at
org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:156)
at
org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestableMethod(TimeoutExtension.java:147)
at
org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestMethod(TimeoutExtension.java:86)
at
org.junit.jupiter.engine.execution.InterceptingExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(InterceptingExecutableInvoker.java:103)
at
org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.lambda$invoke$0(InterceptingExecutableInvoker.java:93)
at
org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)
at
org.junit.jupiter.engine.execution.InvocationInterceptorChain.proceed(InvocationInterceptorChain.java:64)
at
org.junit.jupiter.engine.execution.InvocationInterceptorChain.chainAndInvoke(InvocationInterceptorChain.java:45)
{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
[jira] [Created] (KAFKA-15960) Flaky test: testQuotaOverrideDelete(String).quorum=kraft – kafka.api.ClientIdQuotaTest
Apoorv Mittal created KAFKA-15960:
-
Summary: Flaky test: testQuotaOverrideDelete(String).quorum=kraft
– kafka.api.ClientIdQuotaTest
Key: KAFKA-15960
URL: https://issues.apache.org/jira/browse/KAFKA-15960
Project: Kafka
Issue Type: Bug
Reporter: Apoorv Mittal
PR build:
[https://ci-builds.apache.org/blue/organizations/jenkins/Kafka%2Fkafka-pr/detail/PR-14767/15/tests/]
{code:java}
rg.opentest4j.AssertionFailedError: Client with
id=QuotasTestProducer-!@#$%^&*() should have been throttled, 0.0 ==> expected:
but was: Stacktraceorg.opentest4j.AssertionFailedError: Client
with id=QuotasTestProducer-!@#$%^&*() should have been throttled, 0.0 ==>
expected: but was: at
app//org.junit.jupiter.api.AssertionFailureBuilder.build(AssertionFailureBuilder.java:151)
at
app//org.junit.jupiter.api.AssertionFailureBuilder.buildAndThrow(AssertionFailureBuilder.java:132)
at app//org.junit.jupiter.api.AssertTrue.failNotTrue(AssertTrue.java:63)
at app//org.junit.jupiter.api.AssertTrue.assertTrue(AssertTrue.java:36) at
app//org.junit.jupiter.api.Assertions.assertTrue(Assertions.java:210)at
app//kafka.api.QuotaTestClients.verifyThrottleTimeRequestChannelMetric(BaseQuotaTest.scala:260)
at
app//kafka.api.QuotaTestClients.verifyProduceThrottle(BaseQuotaTest.scala:269)
at
app//kafka.api.BaseQuotaTest.testQuotaOverrideDelete(BaseQuotaTest.scala:157)
at
java.base@17.0.7/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native
Method)at
java.base@17.0.7/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
at
java.base@17.0.7/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
[jira] [Created] (KAFKA-15958) Add tests to validate telemetry requests with different version
Apoorv Mittal created KAFKA-15958: - Summary: Add tests to validate telemetry requests with different version Key: KAFKA-15958 URL: https://issues.apache.org/jira/browse/KAFKA-15958 Project: Kafka Issue Type: Sub-task Reporter: Apoorv Mittal Assignee: Apoorv Mittal Details: https://github.com/apache/kafka/pull/14724#discussion_r1412530561 -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (KAFKA-9545) Flaky Test `RegexSourceIntegrationTest.testRegexMatchesTopicsAWhenDeleted`
[
https://issues.apache.org/jira/browse/KAFKA-9545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17792158#comment-17792158
]
Apoorv Mittal commented on KAFKA-9545:
--
Reoccurred the failure:
https://ci-builds.apache.org/blue/organizations/jenkins/Kafka%2Fkafka-pr/detail/PR-14724/19/tests
{code:java}
Errororg.opentest4j.AssertionFailedError: Condition not met within timeout
15000. Stream tasks not updated ==> expected: but was:
Stacktraceorg.opentest4j.AssertionFailedError: Condition not met within
timeout 15000. Stream tasks not updated ==> expected: but was:
at
app//org.junit.jupiter.api.AssertionFailureBuilder.build(AssertionFailureBuilder.java:151)
at
app//org.junit.jupiter.api.AssertionFailureBuilder.buildAndThrow(AssertionFailureBuilder.java:132)
at app//org.junit.jupiter.api.AssertTrue.failNotTrue(AssertTrue.java:63)
at app//org.junit.jupiter.api.AssertTrue.assertTrue(AssertTrue.java:36) at
app//org.junit.jupiter.api.Assertions.assertTrue(Assertions.java:210)at
app//org.apache.kafka.test.TestUtils.lambda$waitForCondition$3(TestUtils.java:331)
at
app//org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:379)
at app//org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:328)
at app//org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:312)
at app//org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:285)
at
app//org.apache.kafka.streams.integration.RegexSourceIntegrationTest.testRegexMatchesTopicsAWhenDeleted(RegexSourceIntegrationTest.java:295)
at
java.base@11.0.16.1/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native
Method) at
java.base@11.0.16.1/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
java.base@11.0.16.1/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.base@11.0.16.1/java.lang.reflect.Method.invoke(Method.java:566) at
app//org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:728)
at
app//org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60)
at
app//org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)
at
app//org.junit.jupiter.engine.extension.SameThreadTimeoutInvocation.proceed(SameThreadTimeoutInvocation.java:45)
at
app//org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:156)
at
app//org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestableMethod(TimeoutExtension.java:147)
at
app//org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestMethod(TimeoutExtension.java:86)
at
app//org.junit.jupiter.engine.execution.InterceptingExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(InterceptingExecutableInvoker.java:103)
at
app//org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.lambda$invoke$0(InterceptingExecutableInvoker.java:93)
at
app//org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)
{code}
> Flaky Test `RegexSourceIntegrationTest.testRegexMatchesTopicsAWhenDeleted`
> --
>
> Key: KAFKA-9545
> URL: https://issues.apache.org/jira/browse/KAFKA-9545
> Project: Kafka
> Issue Type: Bug
> Components: streams
>Reporter: Jason Gustafson
>Assignee: Boyang Chen
>Priority: Major
>
> https://builds.apache.org/job/kafka-pr-jdk11-scala2.13/4678/testReport/org.apache.kafka.streams.integration/RegexSourceIntegrationTest/testRegexMatchesTopicsAWhenDeleted/
> {code}
> java.lang.AssertionError: Condition not met within timeout 15000. Stream
> tasks not updated
> at org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:26)
> at
> org.apache.kafka.test.TestUtils.lambda$waitForCondition$5(TestUtils.java:367)
> at
> org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:415)
> at
> org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:383)
> at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:366)
> at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:337)
> at
> org.apache.kafka.streams.integration.RegexSourceIntegrationTest.testRegexMatchesTopicsAWhenDeleted(RegexSourceIntegrationTest.java:224)
> at
> java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> at
> java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> at
>
[jira] [Reopened] (KAFKA-9545) Flaky Test `RegexSourceIntegrationTest.testRegexMatchesTopicsAWhenDeleted`
[
https://issues.apache.org/jira/browse/KAFKA-9545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Apoorv Mittal reopened KAFKA-9545:
--
Assignee: (was: Boyang Chen)
> Flaky Test `RegexSourceIntegrationTest.testRegexMatchesTopicsAWhenDeleted`
> --
>
> Key: KAFKA-9545
> URL: https://issues.apache.org/jira/browse/KAFKA-9545
> Project: Kafka
> Issue Type: Bug
> Components: streams
>Reporter: Jason Gustafson
>Priority: Major
>
> https://builds.apache.org/job/kafka-pr-jdk11-scala2.13/4678/testReport/org.apache.kafka.streams.integration/RegexSourceIntegrationTest/testRegexMatchesTopicsAWhenDeleted/
> {code}
> java.lang.AssertionError: Condition not met within timeout 15000. Stream
> tasks not updated
> at org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:26)
> at
> org.apache.kafka.test.TestUtils.lambda$waitForCondition$5(TestUtils.java:367)
> at
> org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:415)
> at
> org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:383)
> at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:366)
> at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:337)
> at
> org.apache.kafka.streams.integration.RegexSourceIntegrationTest.testRegexMatchesTopicsAWhenDeleted(RegexSourceIntegrationTest.java:224)
> at
> java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> at
> java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> at
> java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> at java.base/java.lang.reflect.Method.invoke(Method.java:566)
> at
> org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
> at
> org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
> {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
[jira] [Created] (KAFKA-15952) Create public doc for telemetry state transition
Apoorv Mittal created KAFKA-15952: - Summary: Create public doc for telemetry state transition Key: KAFKA-15952 URL: https://issues.apache.org/jira/browse/KAFKA-15952 Project: Kafka Issue Type: Sub-task Reporter: Apoorv Mittal Assignee: Apoorv Mittal -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (KAFKA-15941) Flaky test: shouldRestoreNullRecord() – org.apache.kafka.streams.integration.RestoreIntegrationTest
Apoorv Mittal created KAFKA-15941:
-
Summary: Flaky test: shouldRestoreNullRecord() –
org.apache.kafka.streams.integration.RestoreIntegrationTest
Key: KAFKA-15941
URL: https://issues.apache.org/jira/browse/KAFKA-15941
Project: Kafka
Issue Type: Bug
Reporter: Apoorv Mittal
https://ci-builds.apache.org/blue/organizations/jenkins/Kafka%2Fkafka-pr/detail/PR-14699/24/tests/
{code:java}
org.opentest4j.AssertionFailedError: Condition not met within timeout 6.
Did not receive all [KeyValue(2, \x00\x00\x00)] records from topic output (got
[]) ==> expected: but was:
Stacktraceorg.opentest4j.AssertionFailedError: Condition not met within
timeout 6. Did not receive all [KeyValue(2, \x00\x00\x00)] records from
topic output (got []) ==> expected: but was: at
org.junit.jupiter.api.AssertionFailureBuilder.build(AssertionFailureBuilder.java:151)
at
org.junit.jupiter.api.AssertionFailureBuilder.buildAndThrow(AssertionFailureBuilder.java:132)
at org.junit.jupiter.api.AssertTrue.failNotTrue(AssertTrue.java:63)
at org.junit.jupiter.api.AssertTrue.assertTrue(AssertTrue.java:36) at
org.junit.jupiter.api.Assertions.assertTrue(Assertions.java:210) at
org.apache.kafka.test.TestUtils.lambda$waitForCondition$3(TestUtils.java:331)
at
org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:379)
at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:328) at
org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:312) at
org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:302) at
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilFinalKeyValueRecordsReceived(IntegrationTestUtils.java:878)
at
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilFinalKeyValueRecordsReceived(IntegrationTestUtils.java:827)
at
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilFinalKeyValueRecordsReceived(IntegrationTestUtils.java:790)
at
org.apache.kafka.streams.integration.RestoreIntegrationTest.shouldRestoreNullRecord(RestoreIntegrationTest.java:244)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
[jira] [Created] (KAFKA-15940) Flaky test: testLogCleanerConfig(String).quorum=kraft – kafka.server.DynamicBrokerReconfigurationTest
Apoorv Mittal created KAFKA-15940:
-
Summary: Flaky test: testLogCleanerConfig(String).quorum=kraft –
kafka.server.DynamicBrokerReconfigurationTest
Key: KAFKA-15940
URL: https://issues.apache.org/jira/browse/KAFKA-15940
Project: Kafka
Issue Type: Bug
Reporter: Apoorv Mittal
[https://ci-builds.apache.org/blue/organizations/jenkins/Kafka%2Fkafka-pr/detail/PR-14699/24/tests/]
{code:java}
org.opentest4j.AssertionFailedError: expected: <8000> but was:
<6000>Stacktraceorg.opentest4j.AssertionFailedError: expected: <8000> but was:
<6000>at
org.junit.jupiter.api.AssertionFailureBuilder.build(AssertionFailureBuilder.java:151)
at
org.junit.jupiter.api.AssertionFailureBuilder.buildAndThrow(AssertionFailureBuilder.java:132)
at
org.junit.jupiter.api.AssertEquals.failNotEqual(AssertEquals.java:197) at
org.junit.jupiter.api.AssertEquals.assertEquals(AssertEquals.java:182) at
org.junit.jupiter.api.AssertEquals.assertEquals(AssertEquals.java:177) at
org.junit.jupiter.api.Assertions.assertEquals(Assertions.java:1141) at
kafka.server.DynamicBrokerReconfigurationTest.$anonfun$waitForConfigOnServer$1(DynamicBrokerReconfigurationTest.scala:1640)
at
kafka.server.DynamicBrokerReconfigurationTest.waitForConfigOnServer(DynamicBrokerReconfigurationTest.scala:1640)
at
kafka.server.DynamicBrokerReconfigurationTest.$anonfun$waitForConfig$1(DynamicBrokerReconfigurationTest.scala:1635)
at
kafka.server.DynamicBrokerReconfigurationTest.$anonfun$waitForConfig$1$adapted(DynamicBrokerReconfigurationTest.scala:1635)
at scala.collection.mutable.ResizableArray.foreach(ResizableArray.scala:62)
at scala.collection.mutable.ResizableArray.foreach$(ResizableArray.scala:55)
at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:49) at
kafka.server.DynamicBrokerReconfigurationTest.waitForConfig(DynamicBrokerReconfigurationTest.scala:1635)
at
kafka.server.DynamicBrokerReconfigurationTest.reconfigureServers(DynamicBrokerReconfigurationTest.scala:1580)
at
kafka.server.DynamicBrokerReconfigurationTest.testLogCleanerConfig(DynamicBrokerReconfigurationTest.scala:568)
{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
[jira] [Created] (KAFKA-15939) Flaky test: testInvalidAlterConfigs(String).quorum=kraft – kafka.api.AdminClientWithPoliciesIntegrationTest
Apoorv Mittal created KAFKA-15939:
-
Summary: Flaky test: testInvalidAlterConfigs(String).quorum=kraft
– kafka.api.AdminClientWithPoliciesIntegrationTest
Key: KAFKA-15939
URL: https://issues.apache.org/jira/browse/KAFKA-15939
Project: Kafka
Issue Type: Bug
Reporter: Apoorv Mittal
[https://ci-builds.apache.org/blue/organizations/jenkins/Kafka%2Fkafka-pr/detail/PR-14699/24/tests/]
{code:java}
org.opentest4j.AssertionFailedError: Topic [invalid-alter-configs-topic-2]
metadata not propagated after 6
msStacktraceorg.opentest4j.AssertionFailedError: Topic
[invalid-alter-configs-topic-2] metadata not propagated after 6 msat
org.junit.jupiter.api.AssertionUtils.fail(AssertionUtils.java:38)at
org.junit.jupiter.api.Assertions.fail(Assertions.java:134) at
kafka.utils.TestUtils$.waitForAllPartitionsMetadata(TestUtils.scala:1141)at
kafka.utils.TestUtils$.createTopicWithAdmin(TestUtils.scala:498) at
kafka.api.PlaintextAdminIntegrationTest$.checkInvalidAlterConfigs(PlaintextAdminIntegrationTest.scala:2699)
at
kafka.api.AdminClientWithPoliciesIntegrationTest.testInvalidAlterConfigs(AdminClientWithPoliciesIntegrationTest.scala:104)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498) at
org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:728)
at
org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60)
at
org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)
{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
[jira] [Created] (KAFKA-15938) Flaky test: testCreateRemoteTopicWithValidRetentionTime(String).quorum=kraft – kafka.admin.RemoteTopicCrudTest
Apoorv Mittal created KAFKA-15938:
-
Summary: Flaky test:
testCreateRemoteTopicWithValidRetentionTime(String).quorum=kraft –
kafka.admin.RemoteTopicCrudTest
Key: KAFKA-15938
URL: https://issues.apache.org/jira/browse/KAFKA-15938
Project: Kafka
Issue Type: Bug
Reporter: Apoorv Mittal
[https://ci-builds.apache.org/blue/organizations/jenkins/Kafka%2Fkafka-pr/detail/PR-14699/24/tests/]
{code:java}
org.opentest4j.AssertionFailedError: Topic [__consumer_offsets] metadata not
propagated after 6 msStacktraceorg.opentest4j.AssertionFailedError: Topic
[__consumer_offsets] metadata not propagated after 6 ms at
org.junit.jupiter.api.AssertionUtils.fail(AssertionUtils.java:38)at
org.junit.jupiter.api.Assertions.fail(Assertions.java:134) at
kafka.utils.TestUtils$.waitForAllPartitionsMetadata(TestUtils.scala:1141)at
kafka.utils.TestUtils$.createTopicWithAdmin(TestUtils.scala:498) at
kafka.utils.TestUtils$.createOffsetsTopicWithAdmin(TestUtils.scala:540) at
kafka.integration.KafkaServerTestHarness.$anonfun$createOffsetsTopic$1(KafkaServerTestHarness.scala:155)
at
kafka.integration.KafkaServerTestHarness.createOffsetsTopic(KafkaServerTestHarness.scala:154)
at
kafka.api.IntegrationTestHarness.doSetup(IntegrationTestHarness.scala:153) at
kafka.api.IntegrationTestHarness.setUp(IntegrationTestHarness.scala:114) at
kafka.admin.RemoteTopicCrudTest.setUp(RemoteTopicCrudTest.scala:71) at
sun.reflect.GeneratedMethodAccessor27.invoke(Unknown Source) at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498) at
org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:728)
at
org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60)
at
org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)
at
org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:156)
{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
[jira] [Created] (KAFKA-15937) Flaky test: testTopicDeletion(String).quorum=kraft – kafka.admin.RemoteTopicCrudTest
Apoorv Mittal created KAFKA-15937:
-
Summary: Flaky test: testTopicDeletion(String).quorum=kraft –
kafka.admin.RemoteTopicCrudTest
Key: KAFKA-15937
URL: https://issues.apache.org/jira/browse/KAFKA-15937
Project: Kafka
Issue Type: Bug
Reporter: Apoorv Mittal
[https://ci-builds.apache.org/blue/organizations/jenkins/Kafka%2Fkafka-pr/detail/PR-14699/24/tests/]
{code:java}
java.lang.RuntimeException: Received a fatal error while waiting for the
controller to acknowledge that we are caught
upStacktracejava.lang.RuntimeException: Received a fatal error while waiting
for the controller to acknowledge that we are caught up at
org.apache.kafka.server.util.FutureUtils.waitWithLogging(FutureUtils.java:68)
at kafka.server.BrokerServer.startup(BrokerServer.scala:472)at
kafka.integration.KafkaServerTestHarness.$anonfun$createBrokers$1(KafkaServerTestHarness.scala:356)
at
kafka.integration.KafkaServerTestHarness.$anonfun$createBrokers$1$adapted(KafkaServerTestHarness.scala:352)
at scala.collection.Iterator.foreach(Iterator.scala:943)at
scala.collection.Iterator.foreach$(Iterator.scala:943) at
scala.collection.AbstractIterator.foreach(Iterator.scala:1431) at
scala.collection.IterableLike.foreach(IterableLike.scala:74) at
scala.collection.IterableLike.foreach$(IterableLike.scala:73)at
scala.collection.AbstractIterable.foreach(Iterable.scala:56) at
kafka.integration.KafkaServerTestHarness.createBrokers(KafkaServerTestHarness.scala:352)
at
kafka.integration.KafkaServerTestHarness.setUp(KafkaServerTestHarness.scala:121)
at
kafka.api.IntegrationTestHarness.doSetup(IntegrationTestHarness.scala:134) at
kafka.api.IntegrationTestHarness.setUp(IntegrationTestHarness.scala:114) at
kafka.admin.RemoteTopicCrudTest.setUp(RemoteTopicCrudTest.scala:71) at
sun.reflect.GeneratedMethodAccessor27.invoke(Unknown Source) at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498) at
org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:728)
at
org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60)
at
org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)
{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
[jira] [Created] (KAFKA-15936) Flaky tests for class: ConnectorTopicsIntegrationTest
Apoorv Mittal created KAFKA-15936:
-
Summary: Flaky tests for class: ConnectorTopicsIntegrationTest
Key: KAFKA-15936
URL: https://issues.apache.org/jira/browse/KAFKA-15936
Project: Kafka
Issue Type: Bug
Reporter: Apoorv Mittal
[https://ci-builds.apache.org/blue/organizations/jenkins/Kafka%2Fkafka-pr/detail/PR-14699/24/tests/]
Build / JDK 8 and Scala 2.12 / testGetActiveTopics –
org.apache.kafka.connect.integration.ConnectorTopicsIntegrationTest1m 50s
{code:java}
Errorjava.lang.RuntimeException: java.util.concurrent.ExecutionException:
org.apache.kafka.common.errors.TimeoutException: The request timed
out.Stacktracejava.lang.RuntimeException:
java.util.concurrent.ExecutionException:
org.apache.kafka.common.errors.TimeoutException: The request timed out. at
org.apache.kafka.connect.util.clusters.EmbeddedKafkaCluster.createTopic(EmbeddedKafkaCluster.java:427)
at
org.apache.kafka.connect.util.clusters.EmbeddedKafkaCluster.createTopic(EmbeddedKafkaCluster.java:401)
at
org.apache.kafka.connect.util.clusters.EmbeddedKafkaCluster.createTopic(EmbeddedKafkaCluster.java:392)
at
org.apache.kafka.connect.integration.ConnectorTopicsIntegrationTest.testGetActiveTopics(ConnectorTopicsIntegrationTest.java:115)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498) at
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
at
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at
org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
at
org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at
org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
at
org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27) at
org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306) at
org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366)at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103)
at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63)
at org.junit.runners.ParentRunner$4.run(ParentRunner.java:331) {code}
Build / JDK 8 and Scala 2.12 / testTopicTrackingResetIsDisabled –
org.apache.kafka.connect.integration.ConnectorTopicsIntegrationTest2m 37s
{code:java}
java.lang.RuntimeException: java.util.concurrent.ExecutionException:
org.apache.kafka.common.errors.TimeoutException: The request timed
out.Stacktracejava.lang.RuntimeException:
java.util.concurrent.ExecutionException:
org.apache.kafka.common.errors.TimeoutException: The request timed out. at
org.apache.kafka.connect.util.clusters.EmbeddedKafkaCluster.createTopic(EmbeddedKafkaCluster.java:427)
at
org.apache.kafka.connect.util.clusters.EmbeddedKafkaCluster.createTopic(EmbeddedKafkaCluster.java:401)
at
org.apache.kafka.connect.util.clusters.EmbeddedKafkaCluster.createTopic(EmbeddedKafkaCluster.java:392)
at
org.apache.kafka.connect.integration.ConnectorTopicsIntegrationTest.testTopicTrackingResetIsDisabled(ConnectorTopicsIntegrationTest.java:179)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498) at
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
at
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at
org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
at
org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at
org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
at
org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27) at
org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306) at
org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366)at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103)
{code}
Build / JDK 8 and Scala 2.12 / testTopicTrackingIsDisabled –
org.apache.kafka.connect.integration.ConnectorTopicsIntegrationTest
{code:java}
java.lang.RuntimeException:
[jira] [Created] (KAFKA-15935) Flaky test: testRestartReplication() – org.apache.kafka.connect.mirror.integration.IdentityReplicationIntegrationTest
Apoorv Mittal created KAFKA-15935:
-
Summary: Flaky test: testRestartReplication() –
org.apache.kafka.connect.mirror.integration.IdentityReplicationIntegrationTest
Key: KAFKA-15935
URL: https://issues.apache.org/jira/browse/KAFKA-15935
Project: Kafka
Issue Type: Bug
Reporter: Apoorv Mittal
[https://ci-builds.apache.org/blue/organizations/jenkins/Kafka%2Fkafka-pr/detail/PR-14699/24/tests/]
{code:java}
Errororg.opentest4j.AssertionFailedError: Condition not met within timeout
3. Topic: mm2-status.backup.internal didn't get created in the cluster ==>
expected: but was: Stacktraceorg.opentest4j.AssertionFailedError:
Condition not met within timeout 3. Topic: mm2-status.backup.internal
didn't get created in the cluster ==> expected: but was: at
org.junit.jupiter.api.AssertionFailureBuilder.build(AssertionFailureBuilder.java:151)
at
org.junit.jupiter.api.AssertionFailureBuilder.buildAndThrow(AssertionFailureBuilder.java:132)
at org.junit.jupiter.api.AssertTrue.failNotTrue(AssertTrue.java:63)
at org.junit.jupiter.api.AssertTrue.assertTrue(AssertTrue.java:36) at
org.junit.jupiter.api.Assertions.assertTrue(Assertions.java:210) at
org.apache.kafka.test.TestUtils.lambda$waitForCondition$3(TestUtils.java:331)
at
org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:379)
at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:328) at
org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:312) at
org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:302) at
org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationBaseTest.waitForTopicCreated(MirrorConnectorsIntegrationBaseTest.java:1041)
at
org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationBaseTest.startClusters(MirrorConnectorsIntegrationBaseTest.java:224)
at
org.apache.kafka.connect.mirror.integration.IdentityReplicationIntegrationTest.startClusters(IdentityReplicationIntegrationTest.java:40)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498) at
org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:728)
{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
[jira] [Created] (KAFKA-15934) Flaky test: testMultiConsumerStickyAssignor(String, String).quorum=kraft+kip848.groupProtocol=generic – kafka.api.PlaintextConsumerTest
Apoorv Mittal created KAFKA-15934:
-
Summary: Flaky test: testMultiConsumerStickyAssignor(String,
String).quorum=kraft+kip848.groupProtocol=generic –
kafka.api.PlaintextConsumerTest
Key: KAFKA-15934
URL: https://issues.apache.org/jira/browse/KAFKA-15934
Project: Kafka
Issue Type: Bug
Reporter: Apoorv Mittal
https://ci-builds.apache.org/blue/organizations/jenkins/Kafka%2Fkafka-pr/detail/PR-14699/24/tests/
{code:java}
Errororg.opentest4j.AssertionFailedError: Timeout waiting for controller
metadata propagating to brokersStacktraceorg.opentest4j.AssertionFailedError:
Timeout waiting for controller metadata propagating to brokers at
app//org.junit.jupiter.api.AssertionUtils.fail(AssertionUtils.java:38) at
app//org.junit.jupiter.api.Assertions.fail(Assertions.java:134) at
app//kafka.utils.TestUtils$.ensureConsistentKRaftMetadata(TestUtils.scala:1141)
at
app//kafka.utils.TestUtils$.$anonfun$createTopicWithAdmin$1(TestUtils.scala:499)
at
app//kafka.utils.TestUtils$.$anonfun$createTopicWithAdmin$1$adapted(TestUtils.scala:499)
at app//scala.collection.immutable.List.foreach(List.scala:333) at
app//kafka.utils.TestUtils$.createTopicWithAdmin(TestUtils.scala:499)at
app//kafka.integration.KafkaServerTestHarness.$anonfun$createTopic$1(KafkaServerTestHarness.scala:184)
at
app//kafka.integration.KafkaServerTestHarness.createTopic(KafkaServerTestHarness.scala:176)
at
app//kafka.api.AbstractConsumerTest.createTopicAndSendRecords(AbstractConsumerTest.scala:176)
at
app//kafka.api.PlaintextConsumerTest.testMultiConsumerStickyAssignor(PlaintextConsumerTest.scala:1001)
at
java.base@11.0.16.1/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native
Method) at
java.base@11.0.16.1/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
java.base@11.0.16.1/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.base@11.0.16.1/java.lang.reflect.Method.invoke(Method.java:566) at
app//org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:728)
at
app//org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60)
at
app//org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)
at
app//org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:156)
at
app//org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestableMethod(TimeoutExtension.java:147)
at
app//org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestTemplateMethod(TimeoutExtension.java:94)
at
app//org.junit.jupiter.engine.execution.InterceptingExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(InterceptingExecutableInvoker.java:103)
at
app//org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.lambda$invoke$0(InterceptingExecutableInvoker.java:93)
at
app//org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)
{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
[jira] [Created] (KAFKA-15933) Flaky test: testRestartReplication() – org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationTransactionsTest
Apoorv Mittal created KAFKA-15933:
-
Summary: Flaky test: testRestartReplication() –
org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationTransactionsTest
Key: KAFKA-15933
URL: https://issues.apache.org/jira/browse/KAFKA-15933
Project: Kafka
Issue Type: Bug
Reporter: Apoorv Mittal
[https://ci-builds.apache.org/blue/organizations/jenkins/Kafka%2Fkafka-pr/detail/PR-14699/24/tests/]
{code:java}
Build / JDK 11 and Scala 2.13 / testRestartReplication() –
org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationTransactionsTest3m
21sErrororg.apache.kafka.common.errors.TimeoutException: Timeout expired after
6ms while awaiting
InitProducerIdStacktraceorg.apache.kafka.common.errors.TimeoutException:
Timeout expired after 6ms while awaiting InitProducerId {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
[jira] [Comment Edited] (KAFKA-15095) Flaky test EosV2UpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosV2[true]
[
https://issues.apache.org/jira/browse/KAFKA-15095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17791123#comment-17791123
]
Apoorv Mittal edited comment on KAFKA-15095 at 11/29/23 2:49 PM:
-
Build:
[https://ci-builds.apache.org/blue/organizations/jenkins/Kafka%2Fkafka-pr/detail/PR-14699/24/tests/]
Build / JDK 8 and Scala 2.12 / shouldUpgradeFromEosAlphaToEosV2[false] –
org.apache.kafka.streams.integration.EosV2UpgradeIntegrationTest
{code:java}
java.lang.AssertionError: expected result: KeyValue(0, 55), KeyValue(0, 66),
KeyValue(0, 78), KeyValue(0, 91), KeyValue(0, 105), KeyValue(2, 55),
KeyValue(2, 66), KeyValue(2, 78), KeyValue(2, 91), KeyValue(2, 105)received
records: KeyValue(1, 55), KeyValue(1, 66), KeyValue(1, 78), KeyValue(1, 91),
KeyValue(1, 105), KeyValue(0, 55), KeyValue(0, 66), KeyValue(0, 78),
KeyValue(0, 91), KeyValue(0, 105), KeyValue(2, 55), KeyValue(2, 66),
KeyValue(2, 78), KeyValue(2, 91), KeyValue(2, 105), KeyValue(3, 55),
KeyValue(3, 66), KeyValue(3, 78), KeyValue(3, 91), KeyValue(3,
105)Stacktracejava.lang.AssertionError: expected result: KeyValue(0, 55),
KeyValue(0, 66), KeyValue(0, 78), KeyValue(0, 91), KeyValue(0, 105),
KeyValue(2, 55), KeyValue(2, 66), KeyValue(2, 78), KeyValue(2, 91), KeyValue(2,
105)received records: KeyValue(1, 55), KeyValue(1, 66), KeyValue(1, 78),
KeyValue(1, 91), KeyValue(1, 105), KeyValue(0, 55), KeyValue(0, 66),
KeyValue(0, 78), KeyValue(0, 91), KeyValue(0, 105), KeyValue(2, 55),
KeyValue(2, 66), KeyValue(2, 78), KeyValue(2, 91), KeyValue(2, 105),
KeyValue(3, 55), KeyValue(3, 66), KeyValue(3, 78), KeyValue(3, 91), KeyValue(3,
105)at
org.apache.kafka.streams.integration.EosV2UpgradeIntegrationTest.checkResultPerKey(EosV2UpgradeIntegrationTest.java:1099)
at
org.apache.kafka.streams.integration.EosV2UpgradeIntegrationTest.verifyCommitted(EosV2UpgradeIntegrationTest.java:1051)
at
org.apache.kafka.streams.integration.EosV2UpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosV2(EosV2UpgradeIntegrationTest.java:397)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498) at
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
at
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
{code}
was (Author: apoorvmittal10):
Build:
https://ci-builds.apache.org/blue/organizations/jenkins/Kafka%2Fkafka-pr/detail/PR-14699/24/tests/
{code:java}
java.lang.AssertionError: expected result: KeyValue(0, 55), KeyValue(0, 66),
KeyValue(0, 78), KeyValue(0, 91), KeyValue(0, 105), KeyValue(2, 55),
KeyValue(2, 66), KeyValue(2, 78), KeyValue(2, 91), KeyValue(2, 105)received
records: KeyValue(1, 55), KeyValue(1, 66), KeyValue(1, 78), KeyValue(1, 91),
KeyValue(1, 105), KeyValue(0, 55), KeyValue(0, 66), KeyValue(0, 78),
KeyValue(0, 91), KeyValue(0, 105), KeyValue(2, 55), KeyValue(2, 66),
KeyValue(2, 78), KeyValue(2, 91), KeyValue(2, 105), KeyValue(3, 55),
KeyValue(3, 66), KeyValue(3, 78), KeyValue(3, 91), KeyValue(3,
105)Stacktracejava.lang.AssertionError: expected result: KeyValue(0, 55),
KeyValue(0, 66), KeyValue(0, 78), KeyValue(0, 91), KeyValue(0, 105),
KeyValue(2, 55), KeyValue(2, 66), KeyValue(2, 78), KeyValue(2, 91), KeyValue(2,
105)received records: KeyValue(1, 55), KeyValue(1, 66), KeyValue(1, 78),
KeyValue(1, 91), KeyValue(1, 105), KeyValue(0, 55), KeyValue(0, 66),
KeyValue(0, 78), KeyValue(0, 91), KeyValue(0, 105), KeyValue(2, 55),
KeyValue(2, 66), KeyValue(2, 78), KeyValue(2, 91), KeyValue(2, 105),
KeyValue(3, 55), KeyValue(3, 66), KeyValue(3, 78), KeyValue(3, 91), KeyValue(3,
105)at
org.apache.kafka.streams.integration.EosV2UpgradeIntegrationTest.checkResultPerKey(EosV2UpgradeIntegrationTest.java:1099)
at
org.apache.kafka.streams.integration.EosV2UpgradeIntegrationTest.verifyCommitted(EosV2UpgradeIntegrationTest.java:1051)
at
org.apache.kafka.streams.integration.EosV2UpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosV2(EosV2UpgradeIntegrationTest.java:397)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498) at
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
at
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
{code}
> Flaky test EosV2UpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosV2[true]
>
[jira] [Commented] (KAFKA-15095) Flaky test EosV2UpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosV2[true]
[
https://issues.apache.org/jira/browse/KAFKA-15095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17791123#comment-17791123
]
Apoorv Mittal commented on KAFKA-15095:
---
Build:
https://ci-builds.apache.org/blue/organizations/jenkins/Kafka%2Fkafka-pr/detail/PR-14699/24/tests/
{code:java}
java.lang.AssertionError: expected result: KeyValue(0, 55), KeyValue(0, 66),
KeyValue(0, 78), KeyValue(0, 91), KeyValue(0, 105), KeyValue(2, 55),
KeyValue(2, 66), KeyValue(2, 78), KeyValue(2, 91), KeyValue(2, 105)received
records: KeyValue(1, 55), KeyValue(1, 66), KeyValue(1, 78), KeyValue(1, 91),
KeyValue(1, 105), KeyValue(0, 55), KeyValue(0, 66), KeyValue(0, 78),
KeyValue(0, 91), KeyValue(0, 105), KeyValue(2, 55), KeyValue(2, 66),
KeyValue(2, 78), KeyValue(2, 91), KeyValue(2, 105), KeyValue(3, 55),
KeyValue(3, 66), KeyValue(3, 78), KeyValue(3, 91), KeyValue(3,
105)Stacktracejava.lang.AssertionError: expected result: KeyValue(0, 55),
KeyValue(0, 66), KeyValue(0, 78), KeyValue(0, 91), KeyValue(0, 105),
KeyValue(2, 55), KeyValue(2, 66), KeyValue(2, 78), KeyValue(2, 91), KeyValue(2,
105)received records: KeyValue(1, 55), KeyValue(1, 66), KeyValue(1, 78),
KeyValue(1, 91), KeyValue(1, 105), KeyValue(0, 55), KeyValue(0, 66),
KeyValue(0, 78), KeyValue(0, 91), KeyValue(0, 105), KeyValue(2, 55),
KeyValue(2, 66), KeyValue(2, 78), KeyValue(2, 91), KeyValue(2, 105),
KeyValue(3, 55), KeyValue(3, 66), KeyValue(3, 78), KeyValue(3, 91), KeyValue(3,
105)at
org.apache.kafka.streams.integration.EosV2UpgradeIntegrationTest.checkResultPerKey(EosV2UpgradeIntegrationTest.java:1099)
at
org.apache.kafka.streams.integration.EosV2UpgradeIntegrationTest.verifyCommitted(EosV2UpgradeIntegrationTest.java:1051)
at
org.apache.kafka.streams.integration.EosV2UpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosV2(EosV2UpgradeIntegrationTest.java:397)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498) at
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
at
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
{code}
> Flaky test EosV2UpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosV2[true]
> -
>
> Key: KAFKA-15095
> URL: https://issues.apache.org/jira/browse/KAFKA-15095
> Project: Kafka
> Issue Type: Test
> Components: unit tests
>Reporter: Divij Vaidya
>Priority: Major
> Labels: flaky-test
>
> {code:java}
> java.lang.AssertionError: Did not receive all 178 records from topic
> multiPartitionOutputTopic within 6 ms, currently accumulated data is
> [KeyValue(1, 0), KeyValue(1, 1), KeyValue(1, 3), KeyValue(1, 6), KeyValue(1,
> 10), KeyValue(1, 15), KeyValue(1, 21), KeyValue(1, 28), KeyValue(1, 36),
> KeyValue(1, 45), KeyValue(1, 55), KeyValue(1, 66), KeyValue(1, 78),
> KeyValue(1, 91), KeyValue(1, 105), KeyValue(1, 120), KeyValue(1, 136),
> KeyValue(1, 153), KeyValue(1, 171), KeyValue(1, 190), KeyValue(1, 120),
> KeyValue(1, 136), KeyValue(1, 153), KeyValue(1, 171), KeyValue(1, 190),
> KeyValue(1, 210), KeyValue(1, 231), KeyValue(1, 253), KeyValue(1, 276),
> KeyValue(1, 300), KeyValue(1, 325), KeyValue(1, 351), KeyValue(1, 378),
> KeyValue(1, 406), KeyValue(1, 435), KeyValue(2, 0), KeyValue(2, 1),
> KeyValue(2, 3), KeyValue(2, 6), KeyValue(2, 10), KeyValue(2, 15), KeyValue(2,
> 21), KeyValue(2, 28), KeyValue(2, 36), KeyValue(2, 45), KeyValue(2, 55),
> KeyValue(2, 66), KeyValue(2, 78), KeyValue(2, 91), KeyValue(2, 105),
> KeyValue(2, 55), KeyValue(2, 66), KeyValue(2, 78), KeyValue(2, 91),
> KeyValue(2, 105), KeyValue(2, 120), KeyValue(2, 136), KeyValue(2, 153),
> KeyValue(2, 171), KeyValue(2, 190), KeyValue(2, 210), KeyValue(2, 231),
> KeyValue(2, 253), KeyValue(2, 276), KeyValue(2, 300), KeyValue(2, 325),
> KeyValue(2, 351), KeyValue(2, 378), KeyValue(2, 406), KeyValue(2, 435),
> KeyValue(2, 435), KeyValue(0, 0), KeyValue(0, 1), KeyValue(0, 3), KeyValue(0,
> 6), KeyValue(0, 10), KeyValue(0, 15), KeyValue(0, 21), KeyValue(0, 28),
> KeyValue(0, 36), KeyValue(0, 45), KeyValue(0, 55), KeyValue(0, 66),
> KeyValue(0, 78), KeyValue(0, 91), KeyValue(0, 55), KeyValue(0, 66),
> KeyValue(0, 78), KeyValue(0, 91), KeyValue(0, 105), KeyValue(0, 120),
> KeyValue(0, 136), KeyValue(0, 153), KeyValue(0, 171), KeyValue(0, 190),
> KeyValue(0, 210), KeyValue(0, 231), KeyValue(0, 253), KeyValue(0, 276),
> KeyValue(0, 300), KeyValue(0, 325), KeyValue(0, 351), KeyValue(0, 378),
> KeyValue(0, 406), KeyValue(0, 435), KeyValue(0, 325),
[jira] [Reopened] (KAFKA-14089) Flaky ExactlyOnceSourceIntegrationTest.testSeparateOffsetsTopic
[
https://issues.apache.org/jira/browse/KAFKA-14089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Apoorv Mittal reopened KAFKA-14089:
---
Assignee: (was: Chris Egerton)
Failure occurred on PR build:
https://ci-builds.apache.org/blue/organizations/jenkins/Kafka%2Fkafka-pr/detail/PR-14699/24/tests/
{code:java}
org.apache.kafka.connect.runtime.rest.errors.ConnectRestException: Could not
execute PUT request. Error response: {"error_code":500,"message":"Request timed
out"}Stacktraceorg.apache.kafka.connect.runtime.rest.errors.ConnectRestException:
Could not execute PUT request. Error response:
{"error_code":500,"message":"Request timed out"} at
org.apache.kafka.connect.util.clusters.EmbeddedConnect.putConnectorConfig(EmbeddedConnect.java:272)
at
org.apache.kafka.connect.util.clusters.EmbeddedConnect.configureConnector(EmbeddedConnect.java:196)
at
org.apache.kafka.connect.util.clusters.EmbeddedConnectCluster.configureConnector(EmbeddedConnectCluster.java:48)
at
org.apache.kafka.connect.integration.ExactlyOnceSourceIntegrationTest.testSeparateOffsetsTopic(ExactlyOnceSourceIntegrationTest.java:776)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498) at
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
at
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at
org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
at
org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at
org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
at
org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27) at
org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306) at
org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366)at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103)
at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63)
at org.junit.runners.ParentRunner$4.run(ParentRunner.java:331) at
org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79) at
org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329)at
org.junit.runners.ParentRunner.access$100(ParentRunner.java:66) at
org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293) at
org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306) {code}
> Flaky ExactlyOnceSourceIntegrationTest.testSeparateOffsetsTopic
> ---
>
> Key: KAFKA-14089
> URL: https://issues.apache.org/jira/browse/KAFKA-14089
> Project: Kafka
> Issue Type: Bug
>Affects Versions: 3.3.0
>Reporter: Mickael Maison
>Priority: Major
> Fix For: 3.3.0
>
> Attachments: failure.txt,
> org.apache.kafka.connect.integration.ExactlyOnceSourceIntegrationTest.testSeparateOffsetsTopic.test.stdout
>
>
> It looks like the sequence got broken around "65535, 65537, 65536, 65539,
> 65538, 65541, 65540, 65543"
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
[jira] [Created] (KAFKA-15901) Implement client changes to support telemetry APIs
Apoorv Mittal created KAFKA-15901: - Summary: Implement client changes to support telemetry APIs Key: KAFKA-15901 URL: https://issues.apache.org/jira/browse/KAFKA-15901 Project: Kafka Issue Type: Sub-task Reporter: Apoorv Mittal Assignee: Apoorv Mittal Implement changes in Java client to support telemetry APIs. The support should be added in Producer, Consumer and Admin client to configure telemetry reporter and support APIs. Corresponding changes in NetworkClient to allow send of telemetry calls from Java client. -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (KAFKA-15900) Flaky test: testOutdatedCoordinatorAssignment() – org.apache.kafka.clients.consumer.internals.EagerConsumerCoordinatorTest
Apoorv Mittal created KAFKA-15900:
-
Summary: Flaky test: testOutdatedCoordinatorAssignment() –
org.apache.kafka.clients.consumer.internals.EagerConsumerCoordinatorTest
Key: KAFKA-15900
URL: https://issues.apache.org/jira/browse/KAFKA-15900
Project: Kafka
Issue Type: Bug
Reporter: Apoorv Mittal
Build run:
[https://ci-builds.apache.org/blue/organizations/jenkins/Kafka%2Fkafka-pr/detail/PR-14620/15/tests/]
{code:java}
org.opentest4j.AssertionFailedError: expected: <1> but was:
<2>Stacktraceorg.opentest4j.AssertionFailedError: expected: <1> but was: <2>
at
app//org.junit.jupiter.api.AssertionFailureBuilder.build(AssertionFailureBuilder.java:151)
at
app//org.junit.jupiter.api.AssertionFailureBuilder.buildAndThrow(AssertionFailureBuilder.java:132)
at
app//org.junit.jupiter.api.AssertEquals.failNotEqual(AssertEquals.java:197) at
app//org.junit.jupiter.api.AssertEquals.assertEquals(AssertEquals.java:150) at
app//org.junit.jupiter.api.AssertEquals.assertEquals(AssertEquals.java:145) at
app//org.junit.jupiter.api.Assertions.assertEquals(Assertions.java:527) at
app//org.apache.kafka.clients.consumer.internals.ConsumerCoordinatorTest.testOutdatedCoordinatorAssignment(ConsumerCoordinatorTest.java:1067)
at
java.base@21.0.1/jdk.internal.reflect.DirectMethodHandleAccessor.invoke(DirectMethodHandleAccessor.java:103)
at java.base@21.0.1/java.lang.reflect.Method.invoke(Method.java:580)at
app//org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:728)
at
app//org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60)
at
app//org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)
at
app//org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:156)
at
app//org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestableMethod(TimeoutExtension.java:147)
at
app//org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestMethod(TimeoutExtension.java:86)
at
app//org.junit.jupiter.engine.execution.InterceptingExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(InterceptingExecutableInvoker.java:103)
at
app//org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.lambda$invoke$0(InterceptingExecutableInvoker.java:93)
at
app//org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)
at
app//org.junit.jupiter.engine.execution.InvocationInterceptorChain.proceed(InvocationInterceptorChain.java:64)
at
app//org.junit.jupiter.engine.execution.InvocationInterceptorChain.chainAndInvoke(InvocationInterceptorChain.java:45)
at
app//org.junit.jupiter.engine.execution.InvocationInterceptorChain.invoke(InvocationInterceptorChain.java:37)
{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
[jira] [Commented] (KAFKA-15898) Flaky test: testFenceMultipleBrokers() – org.apache.kafka.controller.QuorumControllerTest
[
https://issues.apache.org/jira/browse/KAFKA-15898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789715#comment-17789715
]
Apoorv Mittal commented on KAFKA-15898:
---
Another failure reported:
https://ci-builds.apache.org/blue/organizations/jenkins/Kafka%2Fkafka-pr/detail/PR-14620/15/tests/
> Flaky test: testFenceMultipleBrokers() –
> org.apache.kafka.controller.QuorumControllerTest
> -
>
> Key: KAFKA-15898
> URL: https://issues.apache.org/jira/browse/KAFKA-15898
> Project: Kafka
> Issue Type: Bug
>Reporter: Apoorv Mittal
>Priority: Major
>
> Build run:
> [https://ci-builds.apache.org/blue/organizations/jenkins/Kafka%2Fkafka-pr/detail/PR-14699/21/tests/]
>
> {code:java}
> java.util.concurrent.TimeoutException: testFenceMultipleBrokers() timed out
> after 40 secondsStacktracejava.util.concurrent.TimeoutException:
> testFenceMultipleBrokers() timed out after 40 secondsat
> org.junit.jupiter.engine.extension.TimeoutExceptionFactory.create(TimeoutExceptionFactory.java:29)
>at
> org.junit.jupiter.engine.extension.SameThreadTimeoutInvocation.proceed(SameThreadTimeoutInvocation.java:58)
> at
> org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:156)
> at
> org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestableMethod(TimeoutExtension.java:147)
>at
> org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestMethod(TimeoutExtension.java:86)
> at
> org.junit.jupiter.engine.execution.InterceptingExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(InterceptingExecutableInvoker.java:103)
> at
> org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.lambda$invoke$0(InterceptingExecutableInvoker.java:93)
> at
> org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)
> at
> org.junit.jupiter.engine.execution.InvocationInterceptorChain.proceed(InvocationInterceptorChain.java:64)
> at
> org.junit.jupiter.engine.execution.InvocationInterceptorChain.chainAndInvoke(InvocationInterceptorChain.java:45)
> at
> org.junit.jupiter.engine.execution.InvocationInterceptorChain.invoke(InvocationInterceptorChain.java:37)
> at
> org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.invoke(InterceptingExecutableInvoker.java:92)
>at
> org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.invoke(InterceptingExecutableInvoker.java:86)
>at
> org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.lambda$invokeTestMethod$7(TestMethodTestDescriptor.java:218)
> at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> at
> org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.invokeTestMethod(TestMethodTestDescriptor.java:214)
> at
> org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:139)
> at
> org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:69)
>at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:151)
>at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
>at
> org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
> at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
>at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
> at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
> at java.base/java.util.ArrayList.forEach(ArrayList.java:1511) at
> org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:41)
> at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:155)
>at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
>at
> org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
> at
>
[jira] [Commented] (KAFKA-15891) Flaky test: testResetSinkConnectorOffsetsOverriddenConsumerGroupId – org.apache.kafka.connect.integration.OffsetsApiIntegrationTest
[ https://issues.apache.org/jira/browse/KAFKA-15891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789712#comment-17789712 ] Apoorv Mittal commented on KAFKA-15891: --- Another PR build run failure for same test: https://ci-builds.apache.org/blue/organizations/jenkins/Kafka%2Fkafka-pr/detail/PR-14620/15/tests > Flaky test: testResetSinkConnectorOffsetsOverriddenConsumerGroupId – > org.apache.kafka.connect.integration.OffsetsApiIntegrationTest > --- > > Key: KAFKA-15891 > URL: https://issues.apache.org/jira/browse/KAFKA-15891 > Project: Kafka > Issue Type: Bug >Reporter: Apoorv Mittal >Priority: Major > > h4. Error > org.opentest4j.AssertionFailedError: Condition not met within timeout 3. > Sink connector consumer group offsets should catch up to the topic end > offsets ==> expected: but was: > h4. Stacktrace > org.opentest4j.AssertionFailedError: Condition not met within timeout 3. > Sink connector consumer group offsets should catch up to the topic end > offsets ==> expected: but was: > at > app//org.junit.jupiter.api.AssertionFailureBuilder.build(AssertionFailureBuilder.java:151) > at > app//org.junit.jupiter.api.AssertionFailureBuilder.buildAndThrow(AssertionFailureBuilder.java:132) > at app//org.junit.jupiter.api.AssertTrue.failNotTrue(AssertTrue.java:63) > at app//org.junit.jupiter.api.AssertTrue.assertTrue(AssertTrue.java:36) > at app//org.junit.jupiter.api.Assertions.assertTrue(Assertions.java:210) > at > app//org.apache.kafka.test.TestUtils.lambda$waitForCondition$3(TestUtils.java:331) > at > app//org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:379) > at app//org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:328) > at app//org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:312) > at app//org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:302) > at > app//org.apache.kafka.connect.integration.OffsetsApiIntegrationTest.verifyExpectedSinkConnectorOffsets(OffsetsApiIntegrationTest.java:917) > at > app//org.apache.kafka.connect.integration.OffsetsApiIntegrationTest.resetAndVerifySinkConnectorOffsets(OffsetsApiIntegrationTest.java:725) -- This message was sent by Atlassian Jira (v8.20.10#820010)
