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

Class KafkaConfigurationWrapper

java.lang.Object

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

public class KafkaConfigurationWrapper
extends Object

Wrapper class for kafka configuration that allows us to get at its properties. This is in org.apache.kafka.clients.consumer so that we can call the package private constructor.

Constructor Summary

Constructors

Constructor	Description
KafkaConfigurationWrapper(Properties properties)

Method Summary

Modifier and Type	Method	Description
int	getMaxPollIntervalMs()	In Kafka 0.10.0.0 (which we are using), session.timeout.ms.config is used for this.

Methods inherited from class java.lang.Object

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

Constructor Details

KafkaConfigurationWrapper

public KafkaConfigurationWrapper(Properties properties)

Method Details

getMaxPollIntervalMs

public int getMaxPollIntervalMs()

In Kafka 0.10.0.0 (which we are using), session.timeout.ms.config is used for this. In Kafka 0.10.1.0 and later, we need to use the property max.poll.interval.ms See https://kafka.apache.org/0100/documentation.html

Returns:

int