Class KafkaIngester.SinglePartition

java.lang.Object
io.deephaven.kafka.ingest.KafkaIngester.PartitionRange
io.deephaven.kafka.ingest.KafkaIngester.SinglePartition
All Implemented Interfaces:
IntPredicate
Enclosing class:
KafkaIngester

public static class KafkaIngester.SinglePartition extends KafkaIngester.PartitionRange
A predicate for handling a single partition.
  • Constructor Details

    • SinglePartition

      public SinglePartition(int partition)
      Create a predicate for a single partition.
      Parameters:
      partition - the partition to ingest