Package com.bakdata.kafka.streams.kstream

Interface KErrorStreamX<K,V,KR,VR>

Type Parameters:
K - type of keys in the original KStreamX
V - type of values in the original KStreamX
KR - type of keys in the processed KStreamX
VR - type of values in the processed KStreamX
public interface KErrorStreamX<K,V,KR,VR>
KStreamX that contains successfully processed records and errors of a previous operation

  • Method Summary

    Modifier and Type
    Method
    Description
    KStreamX<K,com.bakdata.kafka.ProcessingError<V>>
    errors()
    Get the stream of errors that occurred during processing
    KStreamX<K,com.bakdata.kafka.ProcessingError<V>>
    errors(org.apache.kafka.streams.kstream.Named named)
    Get the stream of errors that occurred during processing
    KStreamX<KR,VR>
    values()
    Get the stream of successfully processed values
    KStreamX<KR,VR>
    values(org.apache.kafka.streams.kstream.Named named)
    Get the stream of successfully processed values

  • Method Details

    • values

      KStreamX<KR,VR> values()
      Get the stream of successfully processed values
      Returns:
      stream of processed values

    • values

      KStreamX<KR,VR> values(org.apache.kafka.streams.kstream.Named named)
      Get the stream of successfully processed values
      Parameters:
      named - name of the processor
      Returns:
      stream of processed values

    • errors

      KStreamX<K,com.bakdata.kafka.ProcessingError<V>> errors()
      Get the stream of errors that occurred during processing
      Returns:
      stream of errors

    • errors

      KStreamX<K,com.bakdata.kafka.ProcessingError<V>> errors(org.apache.kafka.streams.kstream.Named named)
      Get the stream of errors that occurred during processing
      Parameters:
      named - name of the processor
      Returns:
      stream of errors