Build failed in Jenkins: kafka-trunk-jdk11 #1125

See Changes: [github] MINOR: updated documentation where RocksDBStore was being used as the -- [...truncated 2.86 MB...]

Re: [KAFKA-557] Add emit on change support for Kafka Streams

w.r.t. new metric, there is already droppedRecordsSensor which logs: "Skipping record due to null key. topic=[{}] partition=[{}] offset=[{}]", It seems we should introduce another metric which records the skipped (duplicate) values. This way, it is easier to observe the effect when this feature

[jira] [Created] (KAFKA-9496) Flaky Test SslAdminIntegrationTest#testSynchronousAuthorizerAclUpdatesBlockRequestThreads

Matthias J. Sax created KAFKA-9496: -- Summary: Flaky Test SslAdminIntegrationTest#testSynchronousAuthorizerAclUpdatesBlockRequestThreads Key: KAFKA-9496 URL: https://issues.apache.org/jira/browse/KAFKA-9496

[jira] [Created] (KAFKA-9495) Flaky Test ReassignPartitionsClusterTest#shouldListReassignmentsTriggeredByZk

Matthias J. Sax created KAFKA-9495: -- Summary: Flaky Test ReassignPartitionsClusterTest#shouldListReassignmentsTriggeredByZk Key: KAFKA-9495 URL: https://issues.apache.org/jira/browse/KAFKA-9495

Re: [KAFKA-557] Add emit on change support for Kafka Streams

Hi Bruno, Thanks for the reply! I've included some basic description on the reporting strategies in the KIP (I might include more information on that later). I've also worked to add some more details on behavior changes as well as rejected alternatives. Hope it will help facilitate the process.

[jira] [Created] (KAFKA-9494) Include data type of the config in ConfigEntry

Shailesh Panwar created KAFKA-9494: -- Summary: Include data type of the config in ConfigEntry Key: KAFKA-9494 URL: https://issues.apache.org/jira/browse/KAFKA-9494 Project: Kafka Issue Type:

[jira] [Resolved] (KAFKA-9115) Add Roll-up Throughput Sensor for Processing on Source Nodes

[ https://issues.apache.org/jira/browse/KAFKA-9115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-9115. -- Resolution: Fixed > Add Roll-up Throughput Sensor for Processing on Source Nodes >

[jira] [Resolved] (KAFKA-9230) Change User Customizable Metrics API in StreamsMetrics interface

[ https://issues.apache.org/jira/browse/KAFKA-9230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-9230. -- Resolution: Fixed > Change User Customizable Metrics API in StreamsMetrics interface >

Re: [KAFKA-557] Add emit on change support for Kafka Streams

Hi, Richard, thank you for the updated KIP. Regarding your question about the survey, IMO the survey should contain a brief description of the emit (report) strategy of each system and a list of pros and cons. I personally would be interested what emit strategy Flink uses. I have a few comments