Uses of Interface
io.gravitee.gateway.reactive.api.context.kafka.KafkaConnectionContext

Packages that use KafkaConnectionContext

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

Uses of KafkaConnectionContext in io.gravitee.gateway.reactive.api.context.kafka

Methods in io.gravitee.gateway.reactive.api.context.kafka that return KafkaConnectionContext

Modifier and Type	Method	Description
KafkaConnectionContext	KafkaExecutionContext.connectionContext()	Access the connection context.

Uses of KafkaConnectionContext in io.gravitee.gateway.reactive.api.policy.kafka

Methods in io.gravitee.gateway.reactive.api.policy.kafka with parameters of type KafkaConnectionContext

Modifier and Type	Method	Description
io.reactivex.rxjava3.core.Completable	KafkaSecurityPolicy.authenticate(KafkaConnectionContext ctx)	Define the actions to perform during the connection.
io.reactivex.rxjava3.core.Maybe<SecurityToken>	KafkaSecurityPolicy.extractSecurityToken(KafkaConnectionContext ctx)	Extracts the SecurityToken from the kafka connection context.
default io.reactivex.rxjava3.core.Completable	KafkaPolicy.onInitialize(KafkaConnectionContext ctx)	Define the actions to perform once api is deployed and the connection is established.