Package com.bakdata.kafka

Class EnvironmentKafkaConfigParser

java.lang.Object

com.bakdata.kafka.EnvironmentKafkaConfigParser

public final class EnvironmentKafkaConfigParser
extends Object

Parse configuration properties of a Kafka app from environment variables

Method Summary

Modifier and Type	Method	Description
static Map<String,String>	parseVariables(Map<String,String> environment)	Parse a list of environment variables as a streams configuration.

Methods inherited from class java.lang.Object

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

Method Details

parseVariables

public static Map<String,String> parseVariables(Map<String,String> environment)

Parse a list of environment variables as a streams configuration. All variables starting with KAFKA_ prefix are converted. _ are replaced by .

Parameters:

environment - map of environment variables

Returns:

parsed streams configuration