Package io.openlineage.client.transports

Class KafkaConfig

java.lang.Object

io.openlineage.client.transports.KafkaConfig

All Implemented Interfaces:

MergeConfig<KafkaConfig>, TransportConfig, Comparable<TransportConfig>

public final class KafkaConfig
extends Object
implements TransportConfig, MergeConfig<KafkaConfig>

Field Summary

Fields inherited from interface io.openlineage.client.transports.TransportConfig

nameRegistry

Constructor Summary

Constructors

Constructor	Description
KafkaConfig(String topicName, String messageKey, Properties properties)

Method Summary

Modifier and Type	Method	Description
String	getMessageKey()
Properties	getProperties()
String	getTopicName()
KafkaConfig	mergeWithNonNull(KafkaConfig other)	Method to create new config class based on current instance and non-null argument value.
void	setMessageKey(String messageKey)
void	setProperties(Properties properties)
void	setTopicName(String topicName)
String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.openlineage.client.MergeConfig

mergePropertyWith, mergePropertyWith, mergeWith, mergeWithDefaultValue

Methods inherited from interface io.openlineage.client.transports.TransportConfig

compareTo, getName, setName

Constructor Details

KafkaConfig

public KafkaConfig(String topicName,
 String messageKey,
 Properties properties)

Method Details

mergeWithNonNull

public KafkaConfig mergeWithNonNull(KafkaConfig other)

Description copied from interface: MergeConfig

Method to create new config class based on current instance and non-null argument value. In most cases, implementation needs to create a new instance of T, while merging all the properties.

Specified by:

mergeWithNonNull in interface MergeConfig<KafkaConfig>

Parameters:

other - overwrite value

Returns:

merged config entry

toString

public String toString()

Overrides:

toString in class Object

getTopicName

public String getTopicName()

setTopicName

public void setTopicName(String topicName)

getMessageKey

public String getMessageKey()

setMessageKey

public void setMessageKey(String messageKey)

getProperties

public Properties getProperties()

setProperties

public void setProperties(Properties properties)