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>)
modCount| Constructor and Description |
|---|
KafkaTuple() |
KafkaTuple(Object... vals) |
| Modifier and Type | Method and Description |
|---|---|
String |
getStream() |
KafkaTuple |
routedTo(String stream)
Sets the target stream of this Tuple.
|
add, add, addAll, addAll, clear, clone, contains, ensureCapacity, forEach, get, indexOf, isEmpty, iterator, lastIndexOf, listIterator, listIterator, remove, remove, removeAll, removeIf, removeRange, replaceAll, retainAll, set, size, sort, spliterator, subList, toArray, toArray, trimToSizeequals, hashCodecontainsAll, toStringfinalize, getClass, notify, notifyAll, wait, wait, waitcontainsAll, equals, hashCodeparallelStream, streampublic KafkaTuple()
public KafkaTuple(Object... vals)
public KafkaTuple routedTo(String stream)
Sets the target stream of this Tuple.
stream - The target streampublic String getStream()
Copyright © 2021 The Apache Software Foundation. All rights reserved.