Matthias J. Sax created KAFKA-13531:
---------------------------------------
Summary: Flaky test NamedTopologyIntegrationTest
Key: KAFKA-13531
URL: https://issues.apache.org/jira/browse/KAFKA-13531
Project: Kafka
Issue Type: Test
Components: streams, unit tests
Reporter: Matthias J. Sax
org.apache.kafka.streams.integration.NamedTopologyIntegrationTest.shouldRemoveNamedTopologyToRunningApplicationWithMultipleNodesAndResetsOffsets
{quote}java.lang.AssertionError: Did not receive all 3 records from topic
output-stream-2 within 60000 ms, currently accumulated data is [] Expected: is
a value equal to or greater than <3> but: <0> was less than <3> at
org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:20) at
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.lambda$waitUntilMinKeyValueRecordsReceived$1(IntegrationTestUtils.java:648)
at
org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:368)
at
org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:336)
at
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilMinKeyValueRecordsReceived(IntegrationTestUtils.java:644)
at
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilMinKeyValueRecordsReceived(IntegrationTestUtils.java:617)
at
org.apache.kafka.streams.integration.NamedTopologyIntegrationTest.shouldRemoveNamedTopologyToRunningApplicationWithMultipleNodesAndResetsOffsets(NamedTopologyIntegrationTest.java:439){quote}
STDERR
{quote}java.util.concurrent.ExecutionException:
org.apache.kafka.common.errors.GroupSubscribedToTopicException: Deleting
offsets of a topic is forbidden while the consumer group is actively subscribed
to it. at
java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357) at
java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1895) at
org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:165)
at
org.apache.kafka.streams.processor.internals.namedtopology.KafkaStreamsNamedTopologyWrapper.lambda$removeNamedTopology$3(KafkaStreamsNamedTopologyWrapper.java:213)
at
org.apache.kafka.common.internals.KafkaFutureImpl.lambda$whenComplete$2(KafkaFutureImpl.java:107)
at
java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:760)
at
java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:736)
at
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1962)
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.streams.processor.internals.TopologyMetadata.maybeNotifyTopologyVersionWaiters(TopologyMetadata.java:154)
at
org.apache.kafka.streams.processor.internals.StreamThread.checkForTopologyUpdates(StreamThread.java:916)
at
org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:598)
at
org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:575)
Caused by: org.apache.kafka.common.errors.GroupSubscribedToTopicException:
Deleting offsets of a topic is forbidden while the consumer group is actively
subscribed to it. java.util.concurrent.ExecutionException:
org.apache.kafka.common.errors.GroupSubscribedToTopicException: Deleting
offsets of a topic is forbidden while the consumer group is actively subscribed
to it. at
java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357) at
java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1895) at
org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:165)
at
org.apache.kafka.streams.processor.internals.namedtopology.KafkaStreamsNamedTopologyWrapper.lambda$removeNamedTopology$3(KafkaStreamsNamedTopologyWrapper.java:213)
at
org.apache.kafka.common.internals.KafkaFutureImpl.lambda$whenComplete$2(KafkaFutureImpl.java:107)
at
java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:760)
at
java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:736)
at
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1962)
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.streams.processor.internals.TopologyMetadata.maybeNotifyTopologyVersionWaiters(TopologyMetadata.java:154)
at
org.apache.kafka.streams.processor.internals.StreamThread.checkForTopologyUpdates(StreamThread.java:916)
at
org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:598)
at
org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:575)
Caused by: org.apache.kafka.common.errors.GroupSubscribedToTopicException:
Deleting offsets of a topic is forbidden while the consumer group is actively
subscribed to it.{quote}
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
