You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Nilesh Kumar (Jira)" <ji...@apache.org> on 2026/05/15 09:57:00 UTC
[jira] [Assigned] (KAFKA-20587) Flaky : KafkaStreamsTelemetryIntegrationTest > "shouldPushGlobalThreadMetricsToBroker(String, String).recordingLevel=INFO, groupProtocol=streams
[ https://issues.apache.org/jira/browse/KAFKA-20587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Nilesh Kumar reassigned KAFKA-20587:
------------------------------------
Assignee: Nilesh Kumar
> Flaky : KafkaStreamsTelemetryIntegrationTest > "shouldPushGlobalThreadMetricsToBroker(String, String).recordingLevel=INFO, groupProtocol=streams
> ------------------------------------------------------------------------------------------------------------------------------------------------
>
> Key: KAFKA-20587
> URL: https://issues.apache.org/jira/browse/KAFKA-20587
> Project: Kafka
> Issue Type: Task
> Components: streams
> Reporter: Muralidhar Basani
> Assignee: Nilesh Kumar
> Priority: Major
>
> FAILED - KafkaStreamsTelemetryIntegrationTest > "shouldPushGlobalThreadMetricsToBroker(String, String).recordingLevel=INFO, groupProtocol=streams"
>
> {code:java}
> org.apache.kafka.streams.errors.StreamsException: There are no partitions available for topic shouldPushGlobalThreadMetricsToBrokerLN4hWDdfRTSgYuoynFI2Zg-global-store when initializing global store iq-test-store
> at org.apache.kafka.streams.processor.internals.GlobalStateManagerImpl.topicPartitionsForStore(GlobalStateManagerImpl.java:304)
> at org.apache.kafka.streams.processor.internals.GlobalStateManagerImpl.initialize(GlobalStateManagerImpl.java:185)
> at org.apache.kafka.streams.processor.internals.GlobalStateUpdateTask.initialize(GlobalStateUpdateTask.java:82)
> at org.apache.kafka.streams.processor.internals.GlobalStreamThread$StateConsumer.initialize(GlobalStreamThread.java:247)
> at org.apache.kafka.streams.processor.internals.GlobalStreamThread.initialize(GlobalStreamThread.java:417)
> at org.apache.kafka.streams.processor.internals.GlobalStreamThread.run(GlobalStreamThread.java:277){code}
> https://develocity.apache.org/s/bglqbjvx2nvna/tests/task/:streams:integration-tests:test/details/org.apache.kafka.streams.integration.KafkaStreamsTelemetryIntegrationTest/shouldPushGlobalThreadMetricsToBroker(String%2C%20String)%5B4%5D?top-execution=1
--
This message was sent by Atlassian Jira
(v8.20.10#820010)