Package org.springframework.cloud.stream.binder.kafka.streams

Class KafkaStreamsBinderEnvironmentPostProcessor

java.lang.Object

org.springframework.cloud.stream.binder.kafka.streams.KafkaStreamsBinderEnvironmentPostProcessor

All Implemented Interfaces:

org.springframework.boot.env.EnvironmentPostProcessor

public class KafkaStreamsBinderEnvironmentPostProcessor
extends Object
implements org.springframework.boot.env.EnvironmentPostProcessor

EnvironmentPostProcessor to ensure the sendToDlqAndContinue BiFunction is excluded in core Spring Cloud Function by adding it to the ineligible function definitions.

Author:

Soby Chacko, Chris Bono

Constructor Summary

Constructors

Constructor	Description
KafkaStreamsBinderEnvironmentPostProcessor()

Method Summary

Modifier and Type	Method	Description
void	postProcessEnvironment(org.springframework.core.env.ConfigurableEnvironment environment, org.springframework.boot.SpringApplication application)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

KafkaStreamsBinderEnvironmentPostProcessor

public KafkaStreamsBinderEnvironmentPostProcessor()

Method Details

postProcessEnvironment

public void postProcessEnvironment(org.springframework.core.env.ConfigurableEnvironment environment,
 org.springframework.boot.SpringApplication application)

Specified by:

postProcessEnvironment in interface org.springframework.boot.env.EnvironmentPostProcessor