[ 
https://issues.apache.org/jira/browse/KAFKA-20587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18081109#comment-18081109
 ] 

Nilesh Kumar commented on KAFKA-20587:
--------------------------------------

[~muralibasani]  I would like to work on this, Can I take this ?

> 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
>            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)

Reply via email to