[
https://issues.apache.org/jira/browse/KAFKA-16811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17852239#comment-17852239
]
Ganesh Sadanala edited comment on KAFKA-16811 at 6/5/24 1:45 AM:
-----------------------------------------------------------------
[~mjsax] I did not change anything apart from the PR changes.
But when I run the debugger on WordCountProcessorDemo, I see that there is a
flow to start stream thread and calculate punctuate metrics and other thread
metrics, I can clearly observe the metrics changed in `jconsole` when I produce
messages from producers and then stream processing them and consumer consuming
on the terminal.
The flow is from streams.start() -> KafkaStreams#start ->
KafkaStreams#processStreamThread -> StreamThread#runLoop ->
StreamThread#runOnceWithoutProcessingThreads inside which the punctuate method
is invoked but as said above active tasks are empty.
I assume active tasks are non-empty when there are not many instances of
Streams, so I created multiple instances of WordProcessorDemo application
running, still the punctuated value is 0.
was (Author: JIRAUSER305566):
[~mjsax] I did not change anything apart from the PR changes.
But when I run the debugger on WordCountProcessorDemo, I see that there is a
flow to start stream thread and calculate punctuate metrics and other thread
metrics, I can clearly observe the metrics changed in `jconsole` when I produce
messages from producers and then stream processing them and consumer consuming
on the terminal.
The flow is from streams.start() -> KafkaStreams#start ->
KafkaStreams#processStreamThread -> StreamThread#runLoop ->
StreamThread#runOnceWithoutProcessingThreads inside which the punctuate method
is invoked but as said above active tasks are empty.
I assume active tasks are non-empty when there are many instances of Streams,
so I created multiple instances of WordProcessorDemo application running, still
the punctuated value is 0.
> Punctuate Ratio metric almost impossible to track
> -------------------------------------------------
>
> Key: KAFKA-16811
> URL: https://issues.apache.org/jira/browse/KAFKA-16811
> Project: Kafka
> Issue Type: Bug
> Components: streams
> Affects Versions: 3.7.0
> Reporter: Sebastien Viale
> Assignee: Ganesh Sadanala
> Priority: Minor
> Time Spent: 48h
> Remaining Estimate: 0h
>
> The Punctuate ratio metric is returned after the last record of the poll
> loop. It is recomputed in every poll loop.
> After a puntuate, the value is close to 1, but there is little chance that
> metric is sampled at this time.
> So its value is almost always 0.
> A solution could be to apply a kind of "sliding window" to it and report the
> value for the last x seconds.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
