Spring Integration Kafka Support

org.springframework.integration.kafka.core
Class Result<T>

java.lang.Object
  extended by org.springframework.integration.kafka.core.Result<T>

public class Result<T>
extends java.lang.Object

The result of a Kafka SimpleConsumer operation

Author:
Marius Bogoevici

Method Summary
 short getError(Partition partition)
           
 java.util.Map<Partition,java.lang.Short> getErrors()
           
 T getResult(Partition partition)
           
 java.util.Map<Partition,T> getResults()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Method Detail

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

Spring Integration Kafka Support