Package org.apache.kafka.clients.consumer.internals

Interface AbstractFetch.ResponseHandler<T>

Type Parameters:
T - Type of response, usually either ClientResponse or Throwable
Enclosing class:
AbstractFetch
Functional Interface:
This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
@FunctionalInterface protected static interface AbstractFetch.ResponseHandler<T>
Defines the contract for handling fetch responses from brokers.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    handle(org.apache.kafka.common.Node target, org.apache.kafka.clients.FetchSessionHandler.FetchRequestData data, T response)
    Handle the response from the given target

  • Method Details

    • handle

      void handle(org.apache.kafka.common.Node target, org.apache.kafka.clients.FetchSessionHandler.FetchRequestData data, T response)
      Handle the response from the given target