Package io.deephaven.kafka

Class KafkaTools.Consume.KeyOrValueSpec

java.lang.Object

io.deephaven.kafka.KafkaTools.Consume.KeyOrValueSpec

Enclosing class:

KafkaTools.Consume

public abstract static class KafkaTools.Consume.KeyOrValueSpec
extends Object

Class to specify conversion of Kafka KEY or VALUE fields to table columns.

Constructor Summary

Constructors

Constructor	Description
KeyOrValueSpec()

Method Summary

Modifier and Type	Method	Description
protected abstract org.apache.kafka.common.serialization.Deserializer<?>	getDeserializer(KafkaTools.KeyOrValue keyOrValue, io.confluent.kafka.schemaregistry.client.SchemaRegistryClient schemaRegistryClient, Map<String,?> configs)
protected abstract KafkaTools.KeyOrValueIngestData	getIngestData(KafkaTools.KeyOrValue keyOrValue, io.confluent.kafka.schemaregistry.client.SchemaRegistryClient schemaRegistryClient, Map<String,?> configs, MutableInt nextColumnIndexMut, List<ColumnDefinition<?>> columnDefinitionsOut)
protected abstract KeyOrValueProcessor	getProcessor(TableDefinition tableDef, KafkaTools.KeyOrValueIngestData data)
Optional<io.confluent.kafka.schemaregistry.SchemaProvider>	getSchemaProvider()

Methods inherited from class java.lang.Object

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

Constructor Details

KeyOrValueSpec

public KeyOrValueSpec()

Method Details

getDeserializer

protected abstract org.apache.kafka.common.serialization.Deserializer<?> getDeserializer(KafkaTools.KeyOrValue keyOrValue,
 io.confluent.kafka.schemaregistry.client.SchemaRegistryClient schemaRegistryClient,
 Map<String,?> configs)

getIngestData

protected abstract KafkaTools.KeyOrValueIngestData getIngestData(KafkaTools.KeyOrValue keyOrValue,
 io.confluent.kafka.schemaregistry.client.SchemaRegistryClient schemaRegistryClient,
 Map<String,?> configs,
 MutableInt nextColumnIndexMut,
 List<ColumnDefinition<?>> columnDefinitionsOut)

getProcessor

protected abstract KeyOrValueProcessor getProcessor(TableDefinition tableDef,
 KafkaTools.KeyOrValueIngestData data)

getSchemaProvider

Optional<io.confluent.kafka.schemaregistry.SchemaProvider> getSchemaProvider()