Package org.odpi.openmetadata.adapters.eventbus.topic.kafka

Class KafkaOpenMetadataEventConsumer

java.lang.Object

org.odpi.openmetadata.frameworks.auditlog.AuditLoggingBase

org.odpi.openmetadata.adapters.eventbus.topic.kafka.KafkaOpenMetadataEventConsumer

All Implemented Interfaces:

Runnable

public class KafkaOpenMetadataEventConsumer
extends AuditLoggingBase
implements Runnable

KafkaOpenMetadataEventConsumer is used to process events from kafka topic and is part of native Apache Kafka event/messaging infrastructure.

Field Summary

Fields inherited from class org.odpi.openmetadata.frameworks.auditlog.AuditLoggingBase

auditLog

Method Summary

Modifier and Type	Method	Description
void	run()	This is the method that provides the behaviour of the thread.

Methods inherited from class org.odpi.openmetadata.frameworks.auditlog.AuditLoggingBase

logExceptionRecord, logExceptionRecord, logRecord, logRecord

Methods inherited from class java.lang.Object

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

Method Details

run

public void run()

This is the method that provides the behaviour of the thread.

Specified by:

run in interface Runnable