Cloudera Docs

What's new in Streams Messaging Manager

Learn about the new features of Streams Messaging Manager in Cloudera Runtime 7.2.9.

Added timestamp to SMM UI logs

SMM UI logs have timestamps.

Kafka supports producer metric whitelisting

The feature allows producerMetrics to be whitelisted based on a whitelist property that should contain a regex with the allowed client.ids.

In order to enable the feature, set the following properties within Kafka Broker Advanced Configuration Snippet (Safety Valve) for kafka.properties/kafka.properties_role_safety_valve:
  • producer.metrics.whitelist.enabled=true
  • producer.metrics.whitelist=regex containing the whitelist for the desired producer's client.ids

This regex uses the simple java java.util.regex.Pattern class to compile the regex, and uses the match() method on the client.id to determine whether it fits the regex or not.

This feature deletes all the producer timeSeries entities from Service Monitor (CM metricsStore) that do not match the regex.

Also this feature filters the metrics within Kafka itself, so producerMetrics that do not match the regex, would not be reported by the /api/metrics endpoint in the Kafka brokers. Both CM and Kafka use the same Java class and method to filter the metrics.