KafkaIngester.PartitionRoundRobin

java.lang.Object

io.deephaven.kafka.ingest.KafkaIngester.PartitionRoundRobin

All Implemented Interfaces:: IntPredicate

Enclosing class:: KafkaIngester

public static class KafkaIngester.PartitionRoundRobin
extends Object
implements IntPredicate

A predicate for evenly distributing partitions among a set of ingesters.

Constructor Summary

Constructors

Constructor Description

PartitionRoundRobin(int consumerIndex, int consumerCount)
Creates a predicate for evenly distributing partitions among a set of ingesters.
Method Summary

Modifier and Type Method Description

boolean test(int value)

String toString()

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.util.function.IntPredicate
and, negate, or

Constructor Details
- PartitionRoundRobin
  
  public PartitionRoundRobin(int consumerIndex, int consumerCount)
  
  Creates a predicate for evenly distributing partitions among a set of ingesters.
  
  Parameters:
  
  consumerIndex - the index of this consumer; you should have precisely one ingester configured for each index between zero (inclusive) and consumerCount (exclusive)
  
  consumerCount - the number of consumers that will ingest this topic
Method Details
- test
  
  public boolean test(int value)
  
  Specified by:
  
  test in interface IntPredicate
- toString
  
  public String toString()
  
  Overrides:
  
  toString in class Object