Package io.gravitee.gateway.reactive.api.context.kafka

Interface KafkaRequest

All Superinterfaces:
BaseRequest, NativeRequest
public interface KafkaRequest extends NativeRequest
Represents a request that can manipulate a Kafka native request.
Author:
Jeoffrey HAEYAERT (jeoffrey.haeyaert at graviteesource.com), GraviteeSource Team

  • Method Summary

    Modifier and Type
    Method
    Description
    <T extends org.apache.kafka.common.requests.AbstractRequest>
    T
    delegate()
    Access the underlying native Kafka request.
    void
    notifyChange()
    Register that the request has been updated during its processing and need to be rebuilt before sending it.

  • Method Details

    • delegate

      <T extends org.apache.kafka.common.requests.AbstractRequest> T delegate()
      Access the underlying native Kafka request.
      Returns:
      the Kafka native request.

    • notifyChange

      void notifyChange()
      Register that the request has been updated during its processing and need to be rebuilt before sending it.