[jira] [Resolved] (KAFKA-13875) update docs to include topoicId for kafka-topics.sh --describe output
[
https://issues.apache.org/jira/browse/KAFKA-13875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Manyanda Chitimbo resolved KAFKA-13875.
---
Resolution: Fixed
Closing the Jira as it has been fixed by
https://github.com/apache/kafka/pull/12170
> update docs to include topoicId for kafka-topics.sh --describe output
> -
>
> Key: KAFKA-13875
> URL: https://issues.apache.org/jira/browse/KAFKA-13875
> Project: Kafka
> Issue Type: Improvement
> Components: admin
>Affects Versions: 3.2.0
>Reporter: Luke Chen
>Assignee: Richard Joerger
>Priority: Major
> Labels: newbie
>
> The topic describe output in quickstart doc here:
> [https://kafka.apache.org/quickstart] should be updated now.
> {code:java}
> bin/kafka-topics.sh --describe --topic quickstart-events --bootstrap-server
> localhost:9092
> Topic:quickstart-events PartitionCount:1ReplicationFactor:1 Configs:
> Topic: quickstart-events Partition: 0Leader: 0 Replicas: 0 Isr:
> 0{code}
> After Topic Id implementation, we included the topic id info in the output
> now. Also the configs is not empty now. The doc should be updated to avoid
> new users get confused.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
[jira] [Created] (KAFKA-14985) ConnectionQuotasTest.testListenerConnectionRateLimitWhenActualRateAboveLimit() test is flaky
Manyanda Chitimbo created KAFKA-14985:
-
Summary:
ConnectionQuotasTest.testListenerConnectionRateLimitWhenActualRateAboveLimit()
test is flaky
Key: KAFKA-14985
URL: https://issues.apache.org/jira/browse/KAFKA-14985
Project: Kafka
Issue Type: Test
Reporter: Manyanda Chitimbo
The test sometimes fails with the following error
{code:java}
Gradle Test Run :core:test > Gradle Test Executor 14 > ConnectionQuotasTest >
testListenerConnectionRateLimitWhenActualRateAboveLimit() FAILED
java.util.concurrent.ExecutionException:
org.opentest4j.AssertionFailedError: Expected rate (30 +- 7), but got
37.47891810856393 (600 connections / 16.009 sec) ==> expected: <30.0> but was:
<37.47891810856393>
at java.base/java.util.concurrent.FutureTask.report(FutureTask.java:122)
at java.base/java.util.concurrent.FutureTask.get(FutureTask.java:205)
at
kafka.network.ConnectionQuotasTest.$anonfun$testListenerConnectionRateLimitWhenActualRateAboveLimit$3(ConnectionQuotasTest.scala:412)
at scala.collection.immutable.List.foreach(List.scala:333)
at
kafka.network.ConnectionQuotasTest.testListenerConnectionRateLimitWhenActualRateAboveLimit(ConnectionQuotasTest.scala:412)
Caused by:
org.opentest4j.AssertionFailedError: Expected rate (30 +- 7), but got
37.47891810856393 (600 connections / 16.009 sec) ==> expected: <30.0> but was:
<37.47891810856393>
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:86)
at
app//org.junit.jupiter.api.Assertions.assertEquals(Assertions.java:1021)
at
app//kafka.network.ConnectionQuotasTest.acceptConnectionsAndVerifyRate(ConnectionQuotasTest.scala:904)
{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
[jira] [Created] (KAFKA-14984) DynamicBrokerReconfigurationTest.testThreadPoolResize() test is flaky
Manyanda Chitimbo created KAFKA-14984:
-
Summary: DynamicBrokerReconfigurationTest.testThreadPoolResize()
test is flaky
Key: KAFKA-14984
URL: https://issues.apache.org/jira/browse/KAFKA-14984
Project: Kafka
Issue Type: Test
Reporter: Manyanda Chitimbo
The test sometimes fails with the below log
{code:java}
kafka.server.DynamicBrokerReconfigurationTest.testThreadPoolResize() failed,
log available in
.../core/build/reports/testOutput/kafka.server.DynamicBrokerReconfigurationTest.testThreadPoolResize().test.stdoutGradle
Test Run :core:test > Gradle Test Executor 6 >
DynamicBrokerReconfigurationTest > testThreadPoolResize() FAILED
org.opentest4j.AssertionFailedError: Invalid threads: expected 6, got 8:
List(data-plane-kafka-socket-acceptor-ListenerName(PLAINTEXT)-PLAINTEXT-0,
data-plane-kafka-socket-acceptor-ListenerName(PLAINTEXT)-PLAINTEXT-0,
data-plane-kafka-socket-acceptor-ListenerName(INTERNAL)-SSL-0,
data-plane-kafka-socket-acceptor-ListenerName(EXTERNAL)-SASL_SSL-0,
data-plane-kafka-socket-acceptor-ListenerName(INTERNAL)-SSL-0,
data-plane-kafka-socket-acceptor-ListenerName(INTERNAL)-SSL-0,
data-plane-kafka-socket-acceptor-ListenerName(EXTERNAL)-SASL_SSL-0,
data-plane-kafka-socket-acceptor-ListenerName(EXTERNAL)-SASL_SSL-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:211)
at
app//kafka.server.DynamicBrokerReconfigurationTest.verifyThreads(DynamicBrokerReconfigurationTest.scala:1634)
at
app//kafka.server.DynamicBrokerReconfigurationTest.testThreadPoolResize(DynamicBrokerReconfigurationTest.scala:872)
{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
[jira] [Created] (KAFKA-14961) DefaultBackgroundThreadTest.testStartupAndTearDown test is flasky
Manyanda Chitimbo created KAFKA-14961:
-
Summary: DefaultBackgroundThreadTest.testStartupAndTearDown test
is flasky
Key: KAFKA-14961
URL: https://issues.apache.org/jira/browse/KAFKA-14961
Project: Kafka
Issue Type: Test
Reporter: Manyanda Chitimbo
Assignee: Manyanda Chitimbo
When running the test suite locally I noticed the following error
{code:java}
org.opentest4j.AssertionFailedError: 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.AssertTrue.assertTrue(AssertTrue.java:31)
at app//org.junit.jupiter.api.Assertions.assertTrue(Assertions.java:180)
at
app//org.apache.kafka.clients.consumer.internals.DefaultBackgroundThreadTest.testStartupAndTearDown(DefaultBackgroundThreadTest.java:95)
{code}
which happened only once and I could reproduce it again.
I further noticed some NPE in debug logs in the form of
{code:java}
ERROR The background thread failed due to unexpected error
(org.apache.kafka.clients.consumer.internals.DefaultBackgroundThread:166)
java.lang.NullPointerException
at
org.apache.kafka.clients.consumer.internals.DefaultBackgroundThread.handlePollResult(DefaultBackgroundThread.java:200)
at
java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195)
at
java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195)
at
java.base/java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:177)
at
java.base/java.util.HashMap$ValueSpliterator.forEachRemaining(HashMap.java:1675)
at
java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484)
at
java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474)
at
java.base/java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:913)
at
java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
at
java.base/java.util.stream.ReferencePipeline.reduce(ReferencePipeline.java:553)
at
org.apache.kafka.clients.consumer.internals.DefaultBackgroundThread.runOnce(DefaultBackgroundThread.java:187)
at
org.apache.kafka.clients.consumer.internals.DefaultBackgroundThread.run(DefaultBackgroundThread.java:159)
{code}
which is due to missing stubs.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
[jira] [Created] (KAFKA-14959) Remove metrics on ClientQuota Managers shutdown
Manyanda Chitimbo created KAFKA-14959: - Summary: Remove metrics on ClientQuota Managers shutdown Key: KAFKA-14959 URL: https://issues.apache.org/jira/browse/KAFKA-14959 Project: Kafka Issue Type: Improvement Components: core Reporter: Manyanda Chitimbo Assignee: Divij Vaidya Fix For: 3.6.0 We register metrics with the KafkaMetricsGroup in LogCleaner.scala but we don't remove them on shutdown. -- This message was sent by Atlassian Jira (v8.20.10#820010)
