Package com.here.platform.data.client.service.stream.kafka

Class KafkaUtils

java.lang.Object

com.here.platform.data.client.service.stream.kafka.KafkaUtils

public class KafkaUtils
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	KafkaUtils.Tag
static class	KafkaUtils.Tag$

Constructor Summary

Constructors

Constructor	Description
KafkaUtils()

Method Summary

Modifier and Type	Method	Description
static void	appendCredentials(Properties kafkaProperties, String hereToken)
static void	assertProtocolCompatibility(scala.collection.immutable.Seq<String> supported, scala.collection.immutable.Seq<String> server)
static String	getMetrics(scala.collection.mutable.Map<org.apache.kafka.common.MetricName,? extends org.apache.kafka.common.Metric> metrics, org.apache.pekko.event.LoggingAdapter log)
static scala.collection.immutable.Map<String,String>	getMetricsMap(scala.collection.mutable.Map<org.apache.kafka.common.MetricName,? extends org.apache.kafka.common.Metric> metrics, scala.collection.immutable.List<String> metricNames, String clientId, org.apache.pekko.event.LoggingAdapter log)
static String	serializeMetricName(org.apache.kafka.common.Metric metric, scala.collection.immutable.Seq<String> exclude, scala.Option<String> clientId)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

KafkaUtils

public KafkaUtils()

Method Details

assertProtocolCompatibility

public static void assertProtocolCompatibility(scala.collection.immutable.Seq<String> supported,
 scala.collection.immutable.Seq<String> server)

appendCredentials

public static void appendCredentials(Properties kafkaProperties,
 String hereToken)

serializeMetricName

public static String serializeMetricName(org.apache.kafka.common.Metric metric,
 scala.collection.immutable.Seq<String> exclude,
 scala.Option<String> clientId)

getMetrics

public static String getMetrics(scala.collection.mutable.Map<org.apache.kafka.common.MetricName,? extends org.apache.kafka.common.Metric> metrics,
 org.apache.pekko.event.LoggingAdapter log)

getMetricsMap

public static scala.collection.immutable.Map<String,String> getMetricsMap(scala.collection.mutable.Map<org.apache.kafka.common.MetricName,? extends org.apache.kafka.common.Metric> metrics,
 scala.collection.immutable.List<String> metricNames,
 String clientId,
 org.apache.pekko.event.LoggingAdapter log)