Package io.confluent.parallelconsumer

Class ParallelStreamProcessor.ConsumeProduceResult<K,V,KK,VV>

java.lang.Object
io.confluent.parallelconsumer.ParallelStreamProcessor.ConsumeProduceResult<K,V,KK,VV>
Type Parameters:
K - in key
V - in value
KK - out key
VV - out value
Enclosing interface:
ParallelStreamProcessor<K,V>
public static class ParallelStreamProcessor.ConsumeProduceResult<K,V,KK,VV> extends Object
A simple triple structure to capture the set of coinciding data.
  • the record consumer
  • any producer record produced as a result of it's processing
  • the metadata for publishing that record

  • Constructor Details

    • ConsumeProduceResult

      public ConsumeProduceResult(PollContext<K,V> in, org.apache.kafka.clients.producer.ProducerRecord<KK,VV> out, org.apache.kafka.clients.producer.RecordMetadata meta)

  • Method Details

    • getIn

      public PollContext<K,V> getIn()

    • getOut

      public org.apache.kafka.clients.producer.ProducerRecord<KK,VV> getOut()

    • getMeta

      public org.apache.kafka.clients.producer.RecordMetadata getMeta()

    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class Object

    • canEqual

      protected boolean canEqual(Object other)

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object

    • toString

      public String toString()
      Overrides:
      toString in class Object