org.springframework.integration.kafka.core
Class Result<T>
java.lang.Object
org.springframework.integration.kafka.core.Result<T>
public class Result<T>
- extends java.lang.Object
The result of a Kafka SimpleConsumer operation
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
getResults
public java.util.Map<Partition,T> getResults()
getResult
public T getResult(Partition partition)
throws java.lang.IllegalArgumentException
- Throws:
java.lang.IllegalArgumentException
getErrors
public java.util.Map<Partition,java.lang.Short> getErrors()
getError
public short getError(Partition partition)
throws java.lang.IllegalArgumentException
- Throws:
java.lang.IllegalArgumentException