Package org.springframework.integration.kafka.dsl

Class AbstractKafkaChannelSpec<S extends AbstractKafkaChannelSpec<S,C>,C extends AbstractKafkaChannel>

java.lang.Object

org.springframework.integration.dsl.IntegrationComponentSpec<S,C>

org.springframework.integration.dsl.MessageChannelSpec<S,C>

org.springframework.integration.kafka.dsl.AbstractKafkaChannelSpec<S,C>

Type Parameters:

S - the spec type.

C - the channel type.

All Implemented Interfaces:

DisposableBean, FactoryBean<C>, InitializingBean, Lifecycle, Phased, SmartLifecycle, ComponentsRegistration

Direct Known Subclasses:

KafkaPollableChannelSpec, KafkaSubscribableChannelSpec

public abstract class AbstractKafkaChannelSpec<S extends AbstractKafkaChannelSpec<S,C>,C extends AbstractKafkaChannel>
extends MessageChannelSpec<S,C>

Spec for a message channel backed by an Apache Kafka topic.

Since:

5.4

Author:

Gary Russell

Field Summary

Fields

Modifier and Type	Field	Description
protected String	groupId

Fields inherited from class org.springframework.integration.dsl.MessageChannelSpec

channel

Fields inherited from class org.springframework.integration.dsl.IntegrationComponentSpec

logger, PARSER, target

Fields inherited from interface org.springframework.beans.factory.FactoryBean

OBJECT_TYPE_ATTRIBUTE

Fields inherited from interface org.springframework.context.SmartLifecycle

DEFAULT_PHASE

Constructor Summary

Constructors

Constructor	Description
AbstractKafkaChannelSpec()

Method Summary

Modifier and Type	Method	Description
S	groupId(String group)	Set the group id to use on the consumer side.
S	id(String idToSet)	Configure the component identifier.

Methods inherited from class org.springframework.integration.dsl.MessageChannelSpec

datatype, doGet, getComponentsToRegister, interceptor, messageConverter, wireTap, wireTap, wireTap

Methods inherited from class org.springframework.integration.dsl.IntegrationComponentSpec

_this, afterPropertiesSet, destroy, get, getId, getObject, getObjectType, getPhase, isAutoStartup, isRunning, start, stop, stop

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.beans.factory.FactoryBean

isSingleton

Field Details

groupId

@Nullable
protected String groupId

Constructor Details

AbstractKafkaChannelSpec

public AbstractKafkaChannelSpec()

Method Details

id

public S id(@Nullable
 String idToSet)

Description copied from class: IntegrationComponentSpec

Configure the component identifier. Used as the beanName to register the bean in the application context for this component.

Overrides:

id in class IntegrationComponentSpec<S extends AbstractKafkaChannelSpec<S,C>,C extends AbstractKafkaChannel>

Parameters:

idToSet - the id.

Returns:

the spec.

groupId

public S groupId(String group)

Set the group id to use on the consumer side.

Parameters:

group - the group id.

Returns:

the spec.