Package io.openlineage.client.transports

Class KafkaConfig

java.lang.Object

io.openlineage.client.transports.KafkaConfig

All Implemented Interfaces:

TransportConfig

public final class KafkaConfig
extends java.lang.Object
implements TransportConfig

Method Summary

Modifier and Type	Method	Description
java.lang.String	getMessageKey()
java.util.Properties	getProperties()
java.lang.String	getTopicName()
void	setMessageKey(java.lang.String messageKey)
void	setProperties(java.util.Properties properties)
void	setTopicName(java.lang.String topicName)
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Method Detail

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

getTopicName

public java.lang.String getTopicName()

setTopicName

public void setTopicName(java.lang.String topicName)

getMessageKey

public java.lang.String getMessageKey()

setMessageKey

public void setMessageKey(java.lang.String messageKey)

getProperties

public java.util.Properties getProperties()

setProperties

public void setProperties(java.util.Properties properties)