Package io.openlineage.client.transports

Class KafkaTransport

java.lang.Object

io.openlineage.client.transports.Transport

io.openlineage.client.transports.KafkaTransport

All Implemented Interfaces:

AutoCloseable

public final class KafkaTransport
extends Transport

Constructor Summary

Constructors

Constructor	Description
KafkaTransport(@NonNull KafkaConfig kafkaConfig)
KafkaTransport(@NonNull org.apache.kafka.clients.producer.KafkaProducer<String,String> kafkaProducer, @NonNull KafkaConfig kafkaConfig)

Method Summary

Modifier and Type	Method	Description
void	close()
void	emit(OpenLineage.DatasetEvent datasetEvent)
void	emit(OpenLineage.JobEvent jobEvent)
void	emit(OpenLineage.RunEvent runEvent)

Methods inherited from class java.lang.Object

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

Constructor Details

KafkaTransport

public KafkaTransport(@NonNull
 @NonNull KafkaConfig kafkaConfig)

KafkaTransport

public KafkaTransport(@NonNull
 @NonNull org.apache.kafka.clients.producer.KafkaProducer<String,String> kafkaProducer,
 @NonNull
 @NonNull KafkaConfig kafkaConfig)

Method Details

emit

public void emit(@NonNull
 OpenLineage.RunEvent runEvent)

Specified by:

emit in class Transport

emit

public void emit(@NonNull
 OpenLineage.DatasetEvent datasetEvent)

Specified by:

emit in class Transport

emit

public void emit(@NonNull
 OpenLineage.JobEvent jobEvent)

Specified by:

emit in class Transport

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Overrides:

close in class Transport

Throws:

Exception