Package io.deephaven.kafka.ingest
package io.deephaven.kafka.ingest
-
ClassDescriptionConverter from a stream of Kafka records to a Deephaven StreamPublisher.Copy fields from a chunk of Kafka key or value objects to a chunk that will be published to a blink table.Convert an Avro
GenericRecordto Deephaven rows.An ingester that consumes an Apache Kafka topic and a subset of its partitions via one or morestream consumers.A predicate for handling a range of partitions.A predicate for evenly distributing partitions among a set of ingesters.A predicate for handling a single partition.This exception is thrown when there is a failure to consume a Kafka record during Kafka to Deephaven ingestion.Consumer for lists of ConsumerRecords coming from Kafka.An adapter that maps keys and values, possibly each with multiple fields, to single Deephaven columns.