Package io.deephaven.kafka
package io.deephaven.kafka
-
ClassDescriptionUtility class with methods to support consuming from a Change Data Capture (CDC) Kafka stream (as, eg, produced by Debezium) to a Deephaven table.Users specify CDC streams via objects satisfying this interface; the objects are created with static factory methods, the classes implementing this interface are opaque from a user perspective.The options to produce a Kafka stream from a Deephaven table.Class to specify conversion of Kafka KEY or VALUE fields to table columns.A callback which is invoked from the consumer loop, enabling clients to inject logic to be invoked by the Kafka consumer thread.Determines the initial offset to seek to for a given KafkaConsumer and TopicPartition.Enum to specify operations that may apply to either of Kafka KEY or VALUE fields.Class to specify conversion of table columns to Kafka KEY or VALUE fields.Marker interface for
StreamConsumerregistrar provider objects.Type for the resultTablereturned by kafka consumers.Consume data into an in-memory append-only table.Consume data into an in-memory blink table, which will present only newly-available rows to downstream operations and visualizations.Consume data into an in-memory ring table.Re-usable abstract implementation ofStreamPublisherfor stream ingestion to column-chunks.