date:20230616

Re: [VOTE] KIP-937: Improve Message Timestamp Validation

2023-06-16 Thread Luke Chen

+1 (binding) from me.

Thanks.
Luke

On Fri, Jun 16, 2023 at 11:55 PM Beyene, Mehari 
wrote:

> Hello everyone,
>
> I am opening the Volte on KIP-937 here. If we have more to discuss, please
> continue the discussion on the existing thread at:
> https://lists.apache.org/thread/wdpw845q9f5rhf6tz9tdlx3kc1g5zczc
>
> Thank you,
> Mehari
>
>

[jira] [Created] (KAFKA-15100) Unsafe to call tryCompleteFetchResponse on request timeout

2023-06-16 Thread Jira

José Armando García Sancio created KAFKA-15100:
--

 Summary: Unsafe to call tryCompleteFetchResponse on request timeout
 Key: KAFKA-15100
 URL: https://issues.apache.org/jira/browse/KAFKA-15100
 Project: Kafka
  Issue Type: Bug
  Components: kraft
Reporter: José Armando García Sancio
Assignee: José Armando García Sancio


When the fetch request times out the future is completed from the 
"raft-expiration-executor" SystemTimer thread. KafkaRaftClient assumes that 
tryCompleteFetchResponse is always called from the same thread. This invariant 
is violated in this case.
{code:java}
           return future.handle((completionTimeMs, exception) -> {
              if (exception != null) {
                  Throwable cause = exception instanceof ExecutionException ?
                      exception.getCause() : exception;                  // If 
the fetch timed out in purgatory, it means no new data is available,
                  // and we will complete the fetch successfully. Otherwise, if 
there was
                  // any other error, we need to return it.
                  Errors error = Errors.forException(cause);
                  if (error != Errors.REQUEST_TIMED_OUT) {
                      logger.info("Failed to handle fetch from {} at {} due to 
{}",
                          replicaId, fetchPartition.fetchOffset(), error);
                      return buildEmptyFetchResponse(error, Optional.empty());
                  }
              }              // FIXME: `completionTimeMs`, which can be null
              logger.trace("Completing delayed fetch from {} starting at offset 
{} at {}",
                  replicaId, fetchPartition.fetchOffset(), completionTimeMs);   
           return tryCompleteFetchRequest(replicaId, fetchPartition, 
time.milliseconds());
          });
{code}
One solution is to always build an empty response if the future was completed 
exceptionally. This works because the ExpirationService completes the future 
with a `TimeoutException`.

A longer-term solution is to use a more flexible event executor service. This 
would be a service that allows more kinds of event to get scheduled/submitted 
to the KRaft thread.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

[jira] [Created] (KAFKA-15099) Flaky Test kafka.api.TransactionsTest.testBumpTransactionalEpoch(String).quorum=kraft

2023-06-16 Thread Justine Olshan (Jira)

Justine Olshan created KAFKA-15099:
--

 Summary: Flaky Test 
kafka.api.TransactionsTest.testBumpTransactionalEpoch(String).quorum=kraft
 Key: KAFKA-15099
 URL: https://issues.apache.org/jira/browse/KAFKA-15099
 Project: Kafka
  Issue Type: Bug
Reporter: Justine Olshan


This one often fails with: 

org.apache.kafka.common.errors.TimeoutException: Timeout expired after 6ms 
while awaiting InitProducerId

seems like a Kraft only issue.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

[jira] [Created] (KAFKA-15098) KRaft migration does not proceed and broker dies if authorizer.class.name is set

2023-06-16 Thread Ron Dagostino (Jira)

Ron Dagostino created KAFKA-15098:
-

 Summary: KRaft migration does not proceed and broker dies if 
authorizer.class.name is set
 Key: KAFKA-15098
 URL: https://issues.apache.org/jira/browse/KAFKA-15098
 Project: Kafka
  Issue Type: Bug
  Components: kraft
Affects Versions: 3.5.0
Reporter: Ron Dagostino
Assignee: David Arthur


java.lang.IllegalArgumentException: requirement failed: ZooKeeper migration 
does not yet support authorizers. Remove authorizer.class.name before 
performing a migration.




--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #1931

2023-06-16 Thread Apache Jenkins Server

See 


Changes:


--
[...truncated 584150 lines...]
[2023-06-16T20:49:21.444Z] 
[2023-06-16T20:49:21.444Z] > Task :streams:javadoc
[2023-06-16T20:49:22.380Z] > Task :streams:javadocJar
[2023-06-16T20:49:22.380Z] 
[2023-06-16T20:49:22.380Z] > Task :clients:javadoc
[2023-06-16T20:49:22.380Z] 
/home/jenkins/jenkins-agent/workspace/Kafka_kafka_trunk_2/clients/src/main/java/org/apache/kafka/clients/admin/ScramMechanism.java:32:
 warning - Tag @see: missing final '>': "https://cwiki.apache.org/confluence/display/KAFKA/KIP-554%3A+Add+Broker-side+SCRAM+Config+API;>KIP-554:
 Add Broker-side SCRAM Config API
[2023-06-16T20:49:22.380Z] 
[2023-06-16T20:49:22.380Z]  This code is duplicated in 
org.apache.kafka.common.security.scram.internals.ScramMechanism.
[2023-06-16T20:49:22.380Z]  The type field in both files must match and must 
not change. The type field
[2023-06-16T20:49:22.380Z]  is used both for passing ScramCredentialUpsertion 
and for the internal
[2023-06-16T20:49:22.380Z]  UserScramCredentialRecord. Do not change the type 
field."
[2023-06-16T20:49:24.433Z] 
/home/jenkins/jenkins-agent/workspace/Kafka_kafka_trunk_2/clients/src/main/java/org/apache/kafka/common/security/oauthbearer/secured/package-info.java:21:
 warning - Tag @link: reference not found: 
org.apache.kafka.common.security.oauthbearer
[2023-06-16T20:49:25.459Z] 5 warnings
[2023-06-16T20:49:26.485Z] 
[2023-06-16T20:49:26.485Z] > Task :clients:javadocJar
[2023-06-16T20:49:27.681Z] > Task :clients:srcJar
[2023-06-16T20:49:28.884Z] > Task :clients:testJar
[2023-06-16T20:49:28.885Z] > Task :clients:testSrcJar
[2023-06-16T20:49:28.885Z] > Task 
:clients:publishMavenJavaPublicationToMavenLocal
[2023-06-16T20:49:28.885Z] > Task :clients:publishToMavenLocal
[2023-06-16T20:49:42.120Z] > Task :core:compileScala
[2023-06-16T20:51:32.407Z] > Task :core:classes
[2023-06-16T20:51:32.407Z] > Task :core:compileTestJava NO-SOURCE
[2023-06-16T20:51:56.547Z] > Task :core:compileTestScala
[2023-06-16T20:53:34.069Z] > Task :core:testClasses
[2023-06-16T20:54:00.170Z] > Task :streams:compileTestJava
[2023-06-16T20:54:00.170Z] > Task :streams:testClasses
[2023-06-16T20:54:00.170Z] > Task :streams:testJar
[2023-06-16T20:54:00.170Z] > Task :streams:testSrcJar
[2023-06-16T20:54:00.170Z] > Task 
:streams:publishMavenJavaPublicationToMavenLocal
[2023-06-16T20:54:00.170Z] > Task :streams:publishToMavenLocal
[2023-06-16T20:54:00.170Z] 
[2023-06-16T20:54:00.170Z] Deprecated Gradle features were used in this build, 
making it incompatible with Gradle 9.0.
[2023-06-16T20:54:00.170Z] 
[2023-06-16T20:54:00.170Z] You can use '--warning-mode all' to show the 
individual deprecation warnings and determine if they come from your own 
scripts or plugins.
[2023-06-16T20:54:00.170Z] 
[2023-06-16T20:54:00.170Z] See 
https://docs.gradle.org/8.1.1/userguide/command_line_interface.html#sec:command_line_warnings
[2023-06-16T20:54:00.170Z] 
[2023-06-16T20:54:00.170Z] BUILD SUCCESSFUL in 5m 18s
[2023-06-16T20:54:00.170Z] 89 actionable tasks: 35 executed, 54 up-to-date
[Pipeline] sh
[2023-06-16T20:54:02.849Z] + grep ^version= gradle.properties
[2023-06-16T20:54:02.849Z] + cut -d= -f 2
[Pipeline] dir
[2023-06-16T20:54:03.543Z] Running in 
/home/jenkins/jenkins-agent/workspace/Kafka_kafka_trunk_2/streams/quickstart
[Pipeline] {
[Pipeline] sh
[2023-06-16T20:54:05.702Z] + mvn clean install -Dgpg.skip
[2023-06-16T20:54:08.348Z] [INFO] Scanning for projects...
[2023-06-16T20:54:08.348Z] [INFO] 

[2023-06-16T20:54:08.348Z] [INFO] Reactor Build Order:
[2023-06-16T20:54:08.348Z] [INFO] 
[2023-06-16T20:54:08.348Z] [INFO] Kafka Streams :: Quickstart   
 [pom]
[2023-06-16T20:54:08.348Z] [INFO] streams-quickstart-java   
 [maven-archetype]
[2023-06-16T20:54:08.348Z] [INFO] 
[2023-06-16T20:54:08.348Z] [INFO] < 
org.apache.kafka:streams-quickstart >-
[2023-06-16T20:54:08.348Z] [INFO] Building Kafka Streams :: Quickstart 
3.6.0-SNAPSHOT[1/2]
[2023-06-16T20:54:08.348Z] [INFO]   from pom.xml
[2023-06-16T20:54:08.348Z] [INFO] [ pom 
]-
[2023-06-16T20:54:09.290Z] [INFO] 
[2023-06-16T20:54:09.290Z] [INFO] --- clean:3.0.0:clean (default-clean) @ 
streams-quickstart ---
[2023-06-16T20:54:09.290Z] [INFO] 
[2023-06-16T20:54:09.290Z] [INFO] --- remote-resources:1.5:process 
(process-resource-bundles) @ streams-quickstart ---
[2023-06-16T20:54:10.233Z] [INFO] 
[2023-06-16T20:54:10.233Z] [INFO] --- site:3.5.1:attach-descriptor 
(attach-descriptor) @ streams-quickstart ---
[2023-06-16T20:54:11.176Z] [INFO] 
[2023-06-16T20:54:11.176Z] [INFO] --- gpg:1.6:sign (sign-artifacts) @ 
streams-quickstart ---
[2023-06-16T20:54:11.176Z] [INFO]

Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.5 #22

2023-06-16 Thread Apache Jenkins Server

See 


Changes:


--
[...truncated 565529 lines...]
[2023-06-16T18:07:01.069Z] 
[2023-06-16T18:07:01.069Z] Gradle Test Run :core:integrationTest > Gradle Test 
Executor 94 > ZkMigrationClientTest > 
testTopicAndBrokerConfigsMigrationWithSnapshots() STARTED
[2023-06-16T18:07:01.069Z] 
[2023-06-16T18:07:01.069Z] Gradle Test Run :core:integrationTest > Gradle Test 
Executor 94 > ZkMigrationClientTest > 
testTopicAndBrokerConfigsMigrationWithSnapshots() PASSED
[2023-06-16T18:07:01.069Z] 
[2023-06-16T18:07:01.069Z] Gradle Test Run :core:integrationTest > Gradle Test 
Executor 94 > ZkMigrationClientTest > testClaimAndReleaseExistingController() 
STARTED
[2023-06-16T18:07:01.975Z] 
[2023-06-16T18:07:01.975Z] Gradle Test Run :core:integrationTest > Gradle Test 
Executor 94 > ZkMigrationClientTest > testClaimAndReleaseExistingController() 
PASSED
[2023-06-16T18:07:01.975Z] 
[2023-06-16T18:07:01.975Z] Gradle Test Run :core:integrationTest > Gradle Test 
Executor 94 > ZkMigrationClientTest > testClaimAbsentController() STARTED
[2023-06-16T18:07:01.975Z] 
[2023-06-16T18:07:01.975Z] Gradle Test Run :core:integrationTest > Gradle Test 
Executor 94 > ZkMigrationClientTest > testClaimAbsentController() PASSED
[2023-06-16T18:07:01.975Z] 
[2023-06-16T18:07:01.975Z] Gradle Test Run :core:integrationTest > Gradle Test 
Executor 94 > ZkMigrationClientTest > testIdempotentCreateTopics() STARTED
[2023-06-16T18:07:01.975Z] 
[2023-06-16T18:07:01.975Z] Gradle Test Run :core:integrationTest > Gradle Test 
Executor 94 > ZkMigrationClientTest > testIdempotentCreateTopics() PASSED
[2023-06-16T18:07:01.975Z] 
[2023-06-16T18:07:01.975Z] Gradle Test Run :core:integrationTest > Gradle Test 
Executor 94 > ZkMigrationClientTest > testCreateNewTopic() STARTED
[2023-06-16T18:07:01.975Z] 
[2023-06-16T18:07:01.975Z] Gradle Test Run :core:integrationTest > Gradle Test 
Executor 94 > ZkMigrationClientTest > testCreateNewTopic() PASSED
[2023-06-16T18:07:01.975Z] 
[2023-06-16T18:07:01.975Z] Gradle Test Run :core:integrationTest > Gradle Test 
Executor 94 > ZkMigrationClientTest > 
testUpdateExistingTopicWithNewAndChangedPartitions() STARTED
[2023-06-16T18:07:02.884Z] 
[2023-06-16T18:07:02.884Z] Gradle Test Run :core:integrationTest > Gradle Test 
Executor 94 > ZkMigrationClientTest > 
testUpdateExistingTopicWithNewAndChangedPartitions() PASSED
[2023-06-16T18:07:02.884Z] 
[2023-06-16T18:07:02.884Z] Gradle Test Run :core:integrationTest > Gradle Test 
Executor 94 > ZooKeeperClientTest > testZNodeChangeHandlerForDataChange() 
STARTED
[2023-06-16T18:07:02.884Z] 
[2023-06-16T18:07:02.884Z] Gradle Test Run :core:integrationTest > Gradle Test 
Executor 94 > ZooKeeperClientTest > testZNodeChangeHandlerForDataChange() PASSED
[2023-06-16T18:07:02.884Z] 
[2023-06-16T18:07:02.884Z] Gradle Test Run :core:integrationTest > Gradle Test 
Executor 94 > ZooKeeperClientTest > testZooKeeperSessionStateMetric() STARTED
[2023-06-16T18:07:02.884Z] 
[2023-06-16T18:07:02.884Z] Gradle Test Run :core:integrationTest > Gradle Test 
Executor 94 > ZooKeeperClientTest > testZooKeeperSessionStateMetric() PASSED
[2023-06-16T18:07:02.884Z] 
[2023-06-16T18:07:02.884Z] Gradle Test Run :core:integrationTest > Gradle Test 
Executor 94 > ZooKeeperClientTest > testExceptionInBeforeInitializingSession() 
STARTED
[2023-06-16T18:07:03.791Z] 
[2023-06-16T18:07:03.791Z] Gradle Test Run :core:integrationTest > Gradle Test 
Executor 94 > ZooKeeperClientTest > testExceptionInBeforeInitializingSession() 
PASSED
[2023-06-16T18:07:03.791Z] 
[2023-06-16T18:07:03.791Z] Gradle Test Run :core:integrationTest > Gradle Test 
Executor 94 > ZooKeeperClientTest > testGetChildrenExistingZNode() STARTED
[2023-06-16T18:07:03.791Z] 
[2023-06-16T18:07:03.791Z] Gradle Test Run :core:integrationTest > Gradle Test 
Executor 94 > ZooKeeperClientTest > testGetChildrenExistingZNode() PASSED
[2023-06-16T18:07:03.791Z] 
[2023-06-16T18:07:03.791Z] Gradle Test Run :core:integrationTest > Gradle Test 
Executor 94 > ZooKeeperClientTest > testConnection() STARTED
[2023-06-16T18:07:04.809Z] 
[2023-06-16T18:07:04.809Z] Gradle Test Run :core:integrationTest > Gradle Test 
Executor 94 > ZooKeeperClientTest > testConnection() PASSED
[2023-06-16T18:07:04.809Z] 
[2023-06-16T18:07:04.809Z] Gradle Test Run :core:integrationTest > Gradle Test 
Executor 94 > ZooKeeperClientTest > testZNodeChangeHandlerForCreation() STARTED
[2023-06-16T18:07:04.809Z] 
[2023-06-16T18:07:04.809Z] Gradle Test Run :core:integrationTest > Gradle Test 
Executor 94 > ZooKeeperClientTest > testZNodeChangeHandlerForCreation() PASSED
[2023-06-16T18:07:04.809Z] 
[2023-06-16T18:07:04.809Z] Gradle Test Run :core:integrationTest > Gradle Test 
Executor 94 > ZooKeeperClientTest > testGetAclExistingZNode() STARTED
[2023-06-16T18:07:05.832Z] 
[2023-06-16T18:07:05.832Z] Gradle Test Run :core:integrationTest > Gradle Test 
Executor 94 > ZooKeeperClientTest

Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #1930

2023-06-16 Thread Apache Jenkins Server

See 


Changes:


--
[...truncated 574991 lines...]
[Pipeline] }
[Pipeline] // withEnv
[Pipeline] }
[Pipeline] // node
[Pipeline] }
[Pipeline] // timestamps
[Pipeline] }
[Pipeline] // timeout
[Pipeline] }
[Pipeline] // stage
[Pipeline] }
Failed in branch JDK 11 and Scala 2.13
[2023-06-16T16:38:17.820Z] 
[2023-06-16T16:38:17.820Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 185 > RestoreIntegrationTest > shouldRestoreNullRecord() PASSED
[2023-06-16T16:38:17.820Z] 
[2023-06-16T16:38:17.820Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 185 > RestoreIntegrationTest > 
shouldRestoreStateFromSourceTopic(boolean) > [1] true STARTED
[2023-06-16T16:38:17.820Z] 
[2023-06-16T16:38:17.820Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 185 > RestoreIntegrationTest > 
shouldRestoreStateFromSourceTopic(boolean) > [1] true PASSED
[2023-06-16T16:38:17.820Z] 
[2023-06-16T16:38:17.820Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 185 > RestoreIntegrationTest > 
shouldRestoreStateFromSourceTopic(boolean) > [2] false STARTED
[2023-06-16T16:38:20.536Z] 
[2023-06-16T16:38:20.537Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 185 > RestoreIntegrationTest > 
shouldRestoreStateFromSourceTopic(boolean) > [2] false PASSED
[2023-06-16T16:38:20.537Z] 
[2023-06-16T16:38:20.537Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 185 > RestoreIntegrationTest > 
shouldSuccessfullyStartWhenLoggingDisabled(boolean) > [1] true STARTED
[2023-06-16T16:38:22.392Z] 
[2023-06-16T16:38:22.392Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 185 > RestoreIntegrationTest > 
shouldSuccessfullyStartWhenLoggingDisabled(boolean) > [1] true PASSED
[2023-06-16T16:38:22.392Z] 
[2023-06-16T16:38:22.392Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 185 > RestoreIntegrationTest > 
shouldSuccessfullyStartWhenLoggingDisabled(boolean) > [2] false STARTED
[2023-06-16T16:38:24.506Z] 
[2023-06-16T16:38:24.507Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 185 > RestoreIntegrationTest > 
shouldSuccessfullyStartWhenLoggingDisabled(boolean) > [2] false PASSED
[2023-06-16T16:38:24.507Z] 
[2023-06-16T16:38:24.507Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 185 > RestoreIntegrationTest > 
shouldRestoreStateFromChangelogTopic(boolean) > [1] true STARTED
[2023-06-16T16:38:28.656Z] 
[2023-06-16T16:38:28.656Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 185 > RestoreIntegrationTest > 
shouldRestoreStateFromChangelogTopic(boolean) > [1] true PASSED
[2023-06-16T16:38:28.656Z] 
[2023-06-16T16:38:28.656Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 185 > RestoreIntegrationTest > 
shouldRestoreStateFromChangelogTopic(boolean) > [2] false STARTED
[2023-06-16T16:38:30.257Z] 
[2023-06-16T16:38:30.257Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 182 > RestoreIntegrationTest > shouldRestoreNullRecord() PASSED
[2023-06-16T16:38:30.257Z] 
[2023-06-16T16:38:30.257Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 182 > RestoreIntegrationTest > 
shouldRestoreStateFromSourceTopic(boolean) > [1] true STARTED
[2023-06-16T16:38:30.257Z] 
[2023-06-16T16:38:30.257Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 182 > RestoreIntegrationTest > 
shouldRestoreStateFromSourceTopic(boolean) > [1] true PASSED
[2023-06-16T16:38:30.257Z] 
[2023-06-16T16:38:30.257Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 182 > RestoreIntegrationTest > 
shouldRestoreStateFromSourceTopic(boolean) > [2] false STARTED
[2023-06-16T16:38:33.356Z] 
[2023-06-16T16:38:33.356Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 182 > RestoreIntegrationTest > 
shouldRestoreStateFromSourceTopic(boolean) > [2] false PASSED
[2023-06-16T16:38:33.356Z] 
[2023-06-16T16:38:33.356Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 182 > RestoreIntegrationTest > 
shouldSuccessfullyStartWhenLoggingDisabled(boolean) > [1] true STARTED
[2023-06-16T16:38:34.042Z] 
[2023-06-16T16:38:34.042Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 185 > RestoreIntegrationTest > 
shouldRestoreStateFromChangelogTopic(boolean) > [2] false PASSED
[2023-06-16T16:38:36.331Z] 
[2023-06-16T16:38:36.331Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 182 > RestoreIntegrationTest > 
shouldSuccessfullyStartWhenLoggingDisabled(boolean) > [1] true PASSED
[2023-06-16T16:38:36.331Z] 
[2023-06-16T16:38:36.331Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 182 > RestoreIntegrationTest > 
shouldSuccessfullyStartWhenLoggingDisabled(boolean) > [2] false STARTED
[2023-06-16T16:38:39.470Z] 
[2023-06-16T16:38:39.470Z] Gradle Test Run

[jira] [Created] (KAFKA-15097) NoSuchFileException in LogCleaner Operation.

2023-06-16 Thread Mukesh Mishra (Jira)

Mukesh Mishra created KAFKA-15097:
-

 Summary: NoSuchFileException in LogCleaner Operation.
 Key: KAFKA-15097
 URL: https://issues.apache.org/jira/browse/KAFKA-15097
 Project: Kafka
  Issue Type: Bug
  Components: log cleaner
Reporter: Mukesh Mishra
 Attachments: __consumer_offset_49.png, config.txt, log-cleaner.log, 
server.log

Currently we are facing NoSuchFileException in LogCleaner, which is critical 
error as result platform get shutown.
We are running Kafka in Kraft Mode.
The cluster is having 3 Node.
Kafka version - 3.3.1
We are  facing issue systematically, which occurs after retention reached.

Here's the logs of Node 1 for consumer offset 4146 for which we have faced 
NoSuchFileException on 24 may 2023


Config :

[^config.txt]

^Logs :^

^Server Node 1 [^server.log]^

^Log Cleaner :
[^log-cleaner.log]
^

^__consumer_offset_49 directory logs :^

^!__consumer_offset_49.png!^

we suspect that swap operation is culprit as we can see swap file for consumer 
offset 4146 for __consumer_offset_49



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

[VOTE] KIP-937: Improve Message Timestamp Validation

2023-06-16 Thread Beyene, Mehari

Hello everyone,

I am opening the Volte on KIP-937 here. If we have more to discuss, please 
continue the discussion on the existing thread at: 
https://lists.apache.org/thread/wdpw845q9f5rhf6tz9tdlx3kc1g5zczc

Thank you,
Mehari

[jira] [Created] (KAFKA-15096) CVE 2023-34455 - Vulnerability identified with Apache kafka

2023-06-16 Thread Sasikumar Muthukrishnan Sampath (Jira)

Sasikumar Muthukrishnan Sampath created KAFKA-15096:
---

 Summary: CVE 2023-34455 - Vulnerability identified with Apache 
kafka
 Key: KAFKA-15096
 URL: https://issues.apache.org/jira/browse/KAFKA-15096
 Project: Kafka
  Issue Type: Bug
Reporter: Sasikumar Muthukrishnan Sampath


A new vulnerability CVE-2023-34455 is identified with camel-kafka dependencies. 
The vulnerability is coming from snappy-java:1.1.8.4

Version 1.1.10.1 contains a patch for this issue. Please upgrade the 
snappy-java version to fix this issue

 
snappy-java is a fast compressor/decompressor for Java. Due to use of an 
unchecked chunk length, an unrecoverable fatal error can occur in versions 
prior to 1.1.10.1.
The code in the function hasNextChunk in the fileSnappyInputStream.java checks 
if a given stream has more chunks to read. It does that by attempting to read 4 
bytes. If it wasn’t possible to read the 4 bytes, the function returns false. 
Otherwise, if 4 bytes were available, the code treats them as the length of the 
next chunk.
In the case that the `compressed` variable is null, a byte array is allocated 
with the size given by the input data. Since the code doesn’t test the legality 
of the `chunkSize` variable, it is possible to pass a negative number (such as 
0x which is -1), which will cause the code to raise a 
`java.lang.NegativeArraySizeException` exception. A worse case would happen 
when passing a huge positive value (such as 0x7FFF), which would raise the 
fatal `java.lang.OutOfMemoryError` error.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

[GitHub] [kafka-site] mumrah opened a new pull request, #525: Add ZK to KRaft migration docs

2023-06-16 Thread via GitHub



mumrah opened a new pull request, #525:
URL: https://github.com/apache/kafka-site/pull/525

   (no comment)


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: dev-unsubscr...@kafka.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.5 #21

2023-06-16 Thread Apache Jenkins Server

See 


Changes:


--
[...truncated 561953 lines...]
[Pipeline] }
[Pipeline] // withEnv
[Pipeline] }
[Pipeline] // withEnv
[Pipeline] }
[Pipeline] // withEnv
[Pipeline] }
[Pipeline] // node
[Pipeline] }
[Pipeline] // timestamps
[Pipeline] }
[Pipeline] // timeout
[Pipeline] }
[Pipeline] // stage
[Pipeline] }
[2023-06-16T13:54:28.817Z] 
[2023-06-16T13:54:28.817Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 178 > StreamsAssignmentScaleTest > 
testStickyTaskAssignorLargePartitionCount PASSED
[2023-06-16T13:54:28.817Z] 
[2023-06-16T13:54:28.817Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 178 > StreamsAssignmentScaleTest > 
testFallbackPriorTaskAssignorManyStandbys STARTED
[2023-06-16T13:54:42.035Z] 
[2023-06-16T13:54:42.035Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 178 > StreamsAssignmentScaleTest > 
testFallbackPriorTaskAssignorManyStandbys PASSED
[2023-06-16T13:54:42.035Z] 
[2023-06-16T13:54:42.035Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 178 > StreamsAssignmentScaleTest > 
testHighAvailabilityTaskAssignorManyStandbys STARTED
[2023-06-16T13:55:16.896Z] 
[2023-06-16T13:55:16.896Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 178 > StreamsAssignmentScaleTest > 
testHighAvailabilityTaskAssignorManyStandbys PASSED
[2023-06-16T13:55:16.896Z] 
[2023-06-16T13:55:16.896Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 178 > StreamsAssignmentScaleTest > 
testFallbackPriorTaskAssignorLargeNumConsumers STARTED
[2023-06-16T13:55:19.152Z] 
[2023-06-16T13:55:19.152Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 178 > StreamsAssignmentScaleTest > 
testFallbackPriorTaskAssignorLargeNumConsumers PASSED
[2023-06-16T13:55:19.152Z] 
[2023-06-16T13:55:19.152Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 178 > StreamsAssignmentScaleTest > 
testStickyTaskAssignorLargeNumConsumers STARTED
[2023-06-16T13:55:23.180Z] 
[2023-06-16T13:55:23.180Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 178 > StreamsAssignmentScaleTest > 
testStickyTaskAssignorLargeNumConsumers PASSED
[2023-06-16T13:55:24.373Z] 
[2023-06-16T13:55:24.373Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 178 > EmitOnChangeIntegrationTest > 
shouldEmitSameRecordAfterFailover() STARTED
[2023-06-16T13:55:33.204Z] 
[2023-06-16T13:55:33.204Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 178 > EmitOnChangeIntegrationTest > 
shouldEmitSameRecordAfterFailover() PASSED
[2023-06-16T13:55:38.342Z] 
[2023-06-16T13:55:38.342Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 178 > HighAvailabilityTaskAssignorIntegrationTest > 
shouldScaleOutWithWarmupTasksAndPersistentStores(TestInfo) STARTED
[2023-06-16T13:57:02.129Z] 
[2023-06-16T13:57:02.129Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 178 > HighAvailabilityTaskAssignorIntegrationTest > 
shouldScaleOutWithWarmupTasksAndPersistentStores(TestInfo) PASSED
[2023-06-16T13:57:02.129Z] 
[2023-06-16T13:57:02.129Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 178 > HighAvailabilityTaskAssignorIntegrationTest > 
shouldScaleOutWithWarmupTasksAndInMemoryStores(TestInfo) STARTED
[2023-06-16T13:57:09.420Z] 
[2023-06-16T13:57:09.420Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 178 > HighAvailabilityTaskAssignorIntegrationTest > 
shouldScaleOutWithWarmupTasksAndInMemoryStores(TestInfo) PASSED
[2023-06-16T13:57:14.788Z] 
[2023-06-16T13:57:14.788Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 178 > KStreamAggregationDedupIntegrationTest > 
shouldReduce(TestInfo) STARTED
[2023-06-16T13:57:28.875Z] 
[2023-06-16T13:57:28.876Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 178 > KStreamAggregationDedupIntegrationTest > 
shouldReduce(TestInfo) PASSED
[2023-06-16T13:57:28.876Z] 
[2023-06-16T13:57:28.876Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 178 > KStreamAggregationDedupIntegrationTest > 
shouldGroupByKey(TestInfo) STARTED
[2023-06-16T13:57:39.745Z] 
[2023-06-16T13:57:39.745Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 178 > KStreamAggregationDedupIntegrationTest > 
shouldGroupByKey(TestInfo) PASSED
[2023-06-16T13:57:39.745Z] 
[2023-06-16T13:57:39.745Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 178 > KStreamAggregationDedupIntegrationTest > 
shouldReduceWindowed(TestInfo) STARTED
[2023-06-16T13:57:49.892Z] 
[2023-06-16T13:57:49.892Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 178 > KStreamAggregationDedupIntegrationTest > 
shouldReduceWindowed(TestInfo) PASSED
[2023-06-16T13:58:00.109Z] 
[2023-06-16T13:58:00.109Z] Gradle Test Run :streams:integrationTest > Gradle 
Test Executor 178 >

Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #1929

2023-06-16 Thread Apache Jenkins Server

See

[jira] [Created] (KAFKA-15095) Flaky test EosV2UpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosV2[true]

2023-06-16 Thread Divij Vaidya (Jira)

Divij Vaidya created KAFKA-15095:


 Summary: 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


{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), 
KeyValue(0, 351), KeyValue(0, 378), KeyValue(0, 406), KeyValue(0, 435), 
KeyValue(3, 0), KeyValue(3, 1), KeyValue(3, 3), KeyValue(3, 6), KeyValue(3, 
10), KeyValue(3, 15), KeyValue(3, 21), KeyValue(3, 28), KeyValue(3, 36), 
KeyValue(3, 45), KeyValue(3, 55), KeyValue(3, 66), KeyValue(3, 78), KeyValue(3, 
91), KeyValue(3, 105), KeyValue(3, 120), KeyValue(3, 136), KeyValue(3, 153), 
KeyValue(3, 171), KeyValue(3, 190), KeyValue(3, 120), KeyValue(3, 136), 
KeyValue(3, 153), KeyValue(3, 171), KeyValue(3, 190), KeyValue(3, 210), 
KeyValue(3, 231), KeyValue(3, 253), KeyValue(3, 276), KeyValue(3, 300), 
KeyValue(3, 325), KeyValue(3, 351), KeyValue(3, 378), KeyValue(3, 406), 
KeyValue(3, 435), KeyValue(1, 465), KeyValue(1, 496), KeyValue(0, 465), 
KeyValue(0, 496), KeyValue(3, 465), KeyValue(3, 496), KeyValue(0, 528), 
KeyValue(1, 528), KeyValue(0, 561), KeyValue(1, 561), KeyValue(0, 595), 
KeyValue(3, 528), KeyValue(2, 465), KeyValue(3, 561), KeyValue(2, 496), 
KeyValue(3, 595), KeyValue(2, 528), KeyValue(2, 561), KeyValue(2, 
595)]Expected: is a value equal to or greater than <178> but: <164> was 
less than <178>   at 
org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:20) at 
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.lambda$waitUntilMinKeyValueRecordsReceived$1(IntegrationTestUtils.java:730)
  at 
org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:379) 
 at 
org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:347) 
 at 
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilMinKeyValueRecordsReceived(IntegrationTestUtils.java:726)
   at 
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilMinKeyValueRecordsReceived(IntegrationTestUtils.java:699)
   at 
org.apache.kafka.streams.integration.EosV2UpgradeIntegrationTest.readResult(EosV2UpgradeIntegrationTest.java:1080)
   at 
org.apache.kafka.streams.integration.EosV2UpgradeIntegrationTest.verifyUncommitted(EosV2UpgradeIntegrationTest.java:1055)
at 
org.apache.kafka.streams.integration.EosV2UpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosV2(EosV2UpgradeIntegrationTest.java:705)
  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)

[jira] [Resolved] (KAFKA-15066) passing listener name config into TopicBasedRemoteLogMetadataManagerConfig

2023-06-16 Thread Luke Chen (Jira)



 [ 
https://issues.apache.org/jira/browse/KAFKA-15066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Luke Chen resolved KAFKA-15066.
---
Fix Version/s: 3.6.0
   Resolution: Fixed

> passing listener name config into TopicBasedRemoteLogMetadataManagerConfig
> --
>
> Key: KAFKA-15066
> URL: https://issues.apache.org/jira/browse/KAFKA-15066
> Project: Kafka
>  Issue Type: Sub-task
>Reporter: Luke Chen
>Assignee: Luke Chen
>Priority: Major
> Fix For: 3.6.0
>
>
> The `remote.log.metadata.manager.listener.name` config doesn't pass to 
> TopicBasedRemoteLogMetadataManagerConfig correctly.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Re: [ANNOUNCE] New committer: Divij Vaidya

2023-06-16 Thread ShunKang Lin

Congratulations, Divij!

Bill Bejeck  于2023年6月16日周五 09:43写道：

> Congratulations!!
>
> On Tue, Jun 13, 2023 at 7:14 PM ziming deng 
> wrote:
>
> > Congratulations, Divij!
> > Well deserved!
> >
> > --
> > Ziming
> >
> > > On Jun 14, 2023, at 09:41, Luke Chen  wrote:
> > >
> > > Congratulations, Divij!
> > > Well deserved!
> > >
> > > Luke
> > >
> > > On Wed, Jun 14, 2023 at 7:01 AM Viktor Somogyi-Vass
> > >  wrote:
> > >
> > >> Congrats Divij!
> > >>
> > >> On Tue, Jun 13, 2023, 20:27 Philip Nee  wrote:
> > >>
> > >>> Congrats!
> > >>>
> > >>> On Tue, Jun 13, 2023 at 8:17 PM Randall Hauch 
> > wrote:
> > >>>
> >  Congratulations!
> > 
> >  On Tue, Jun 13, 2023 at 12:48 PM Matthias J. Sax 
> > >>> wrote:
> > 
> > > Congrats!
> > >
> > > On 6/13/23 10:24 AM, Satish Duggana wrote:
> > >> Congratulations Divij!!
> > >>
> > >> On Tue, 13 Jun 2023 at 22:41, Manyanda Chitimbo
> > >>  wrote:
> > >>>
> > >>> Congratulations Divij.
> > >>>
> > >>> On Tue 13 Jun 2023 at 17:50, Bruno Cadonna 
> >  wrote:
> > >>>
> >  Hi all,
> > 
> >  The PMC of Apache Kafka is pleased to announce a new Kafka
> > >>> committer
> >  Divij Vaidya.
> > 
> >  Divij's major contributions are:
> > 
> >  GDPR compliance enforcement of kafka-site -
> >  https://issues.apache.org/jira/browse/KAFKA-13868
> > 
> >  Performance improvements:
> > 
> >  Improve performance of VarInt encoding and decoding -
> >  https://github.com/apache/kafka/pull/13312
> > 
> >  Reduce data copy & buffer allocation during decompression -
> >  https://github.com/apache/kafka/pull/13135
> > 
> >  He also was heavily involved in the migration to Mockito.
> > 
> >  Furthermore, Divij is very active on the mailing lists as well
> as
> > >>> in
> >  maintaining and reviewing pull requests.
> > 
> >  Congratulations, Divij!
> > 
> >  Thanks,
> > 
> >  Bruno (on behalf of the Apache Kafka PMC)
> > 
> > 
> >  --
> > >>> Manyanda Chitimbo.
> > >
> > 
> > >>>
> > >>
> >
> >
>

TAC Applications for Community Over Code North America and Asia now open

2023-06-16 Thread Gavin McDonald

Hi All,

(This email goes out to all our user and dev project mailing lists, so you
may receive this
email more than once.)

The Travel Assistance Committee has opened up applications to help get
people to the following events:


*Community Over Code Asia 2023 - *
*August 18th to August 20th in Beijing , China*

Applications for this event closes on the 6th July so time is short, please
apply as soon as possible. TAC is prioritising applications from the Asia
and Oceania regions.

More details on this event can be found at:
https://apachecon.com/acasia2023/

More information on how to apply please read: https://tac.apache.org/


*Community Over Code North America - *
*October 7th to October 10th in Halifax, Canada*

Applications for this event closes on the 22nd July. We expect many
applications so please do apply as soon as you can. TAC is prioritising
applications from the North and South America regions.

More details on this event can be found at: https://communityovercode.org/

More information on how to apply please read: https://tac.apache.org/


*Have you applied to be a Speaker?*

If you have applied or intend to apply as a Speaker at either of these
events, and think you
may require assistance for Travel and/or Accommodation - TAC advises that
you do not
wait until you have been notified of your speaker status and to apply
early. Should you
not be accepted as a speaker and still wish to attend you can amend you
application to
include Conference fees, or, you may withdraw your application.

The call for presentations for Halifax is here:
https://communityovercode.org/call-for-presentations/
and you have until the 13th of July to apply.

The call for presentations for Beijing is here:
https://apachecon.com/acasia2023/cfp.html
and you have until the 18th June to apply.

*IMPORTANT Note on Visas:*

It is important that you apply for a Visa as soon as possible - do not wait
until you know if you have been accepted for Travel Assistance or not, as
due to current wait times for Interviews in some Countries, waiting that
long may be too late, so please do apply for a Visa right away. Contact
tac-ap...@tac.apache.org if you need any more information or assistance in
this area.

*Spread the Word!!*

TAC encourages you to spread the word about Travel Assistance to get to
these events, so feel free to repost as you see fit on Social Media, at
work, schools, universities etc etc...

Thank You and hope to see you all soon

Gavin McDonald on behalf of the ASF Travel Assistance Committee.

Re: Permissions to contribute to Apache Kafka.

2023-06-16 Thread Josep Prat

Hi Vaibhav,

I just checked and you have all the right permissions, someone was faster
than me setting it up for you.

Best,

On Fri, Jun 16, 2023 at 8:10 AM Vaibhav Nazare
 wrote:

> HI Team,
> I work with power(ppc64le) team and need permissions to contribute to
> Apache Kafka to enable CI for ppc64le arch.
>
> Requesting you to grant access to contribute to Apache Kafka.
>
> Following are the details for
> Wiki id
> Email: vaibhav.naz...@ibm.com
> Username: vnazare
>
> Jira id
> Email: vaibhav.naz...@ibm.com
> Username: vnazare
>
>

-- 
[image: Aiven] 

*Josep Prat*
Open Source Engineering Director, *Aiven*
josep.p...@aiven.io   |   +491715557497
aiven.io    |   
     
*Aiven Deutschland GmbH*
Alexanderufer 3-7, 10117 Berlin
Geschäftsführer: Oskari Saarenmaa & Hannu Valtonen
Amtsgericht Charlottenburg, HRB 209739 B

Permissions to contribute to Apache Kafka.

2023-06-16 Thread Vaibhav Nazare

HI Team,
I work with the power(ppc64le) team and need permissions to contribute to 
Apache Kafka to enable CI for ppc64le arch.

Requesting you to grant access to contribute to Apache Kafka.

Following are the details for
Wiki id
Email: vaibhav.naz...@ibm.com
Username: vnazare

Jira id
Email: vaibhav.naz...@ibm.com
Username: vnazare

Thanks,
Vaibhav

Permissions to contribute to Apache Kafka.

2023-06-16 Thread Vaibhav Nazare

HI Team,
I work with power(ppc64le) team and need permissions to contribute to Apache 
Kafka to enable CI for ppc64le arch.

Requesting you to grant access to contribute to Apache Kafka.

Following are the details for
Wiki id
Email: vaibhav.naz...@ibm.com
Username: vnazare

Jira id
Email: vaibhav.naz...@ibm.com
Username: vnazare

[jira] [Created] (KAFKA-15094) Add RemoteIndexCache metrics like misses/evictions/load-failures.

2023-06-16 Thread Satish Duggana (Jira)

Satish Duggana created KAFKA-15094:
--

 Summary: Add RemoteIndexCache metrics like 
misses/evictions/load-failures.
 Key: KAFKA-15094
 URL: https://issues.apache.org/jira/browse/KAFKA-15094
 Project: Kafka
  Issue Type: Sub-task
Reporter: Satish Duggana


Add metrics like hits/misses/evictions/load-failures for RemoteIndexCache.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Re: [VOTE] KIP-937: Improve Message Timestamp Validation

[jira] [Created] (KAFKA-15100) Unsafe to call tryCompleteFetchResponse on request timeout

[jira] [Created] (KAFKA-15099) Flaky Test kafka.api.TransactionsTest.testBumpTransactionalEpoch(String).quorum=kraft

[jira] [Created] (KAFKA-15098) KRaft migration does not proceed and broker dies if authorizer.class.name is set

Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #1931

Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.5 #22

Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #1930

[jira] [Created] (KAFKA-15097) NoSuchFileException in LogCleaner Operation.

[VOTE] KIP-937: Improve Message Timestamp Validation

[jira] [Created] (KAFKA-15096) CVE 2023-34455 - Vulnerability identified with Apache kafka

[GitHub] [kafka-site] mumrah opened a new pull request, #525: Add ZK to KRaft migration docs

Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.5 #21

Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #1929

[jira] [Created] (KAFKA-15095) Flaky test EosV2UpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosV2[true]

[jira] [Resolved] (KAFKA-15066) passing listener name config into TopicBasedRemoteLogMetadataManagerConfig

Re: [ANNOUNCE] New committer: Divij Vaidya

TAC Applications for Community Over Code North America and Asia now open

Re: Permissions to contribute to Apache Kafka.

Permissions to contribute to Apache Kafka.

Permissions to contribute to Apache Kafka.

[jira] [Created] (KAFKA-15094) Add RemoteIndexCache metrics like misses/evictions/load-failures.

21 matches

Site Navigation

Mail list logo

Footer information