This is an automated email from the ASF dual-hosted git repository.
guozhang pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from e70e5d9 KAFKA-9505: Only loop over topics-to-validate in retries (#8039)
add 3dfc6c1 KAFKA-9480: Fix bug that prevented to measure task-level process-rate (#8018)
No new revisions were added by this update.
Summary of changes:
.../kafka/streams/processor/internals/SourceNode.java | 9 +++++++--
.../apache/kafka/common/metrics/SensorAccessor.java | 19 +++++++++++--------
.../streams/processor/internals/SourceNodeTest.java | 13 +++++++++++++
3 files changed, 31 insertions(+), 10 deletions(-)
copy clients/src/main/java/org/apache/kafka/common/config/Config.java => streams/src/test/java/org/apache/kafka/common/metrics/SensorAccessor.java
(70%)
|