Class KafkaTuple

All Implemented Interfaces:
Serializable, Cloneable, Iterable<Object>, Collection<Object>, List<Object>, RandomAccess

public class KafkaTuple extends Values
A list of Values in a tuple that can be routed to a given stream: RecordTranslator.apply(org.apache.kafka.clients.consumer.ConsumerRecord<K, V>).
See Also:
  • Constructor Details

    • KafkaTuple

      public KafkaTuple()
    • KafkaTuple

      public KafkaTuple(Object... vals)
  • Method Details

    • routedTo

      public KafkaTuple routedTo(String stream)
      Sets the target stream of this Tuple.
      stream - The target stream
    • getStream

      public String getStream()