Package org.springframework.integration.kafka.dsl

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

java.lang.Object

org.springframework.beans.factory.config.AbstractFactoryBean<T>

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:

Aware, BeanClassLoaderAware, BeanFactoryAware, 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

PARSER, target

Fields inherited from class org.springframework.beans.factory.config.AbstractFactoryBean

logger

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, createInstance, destroyInstance, get, getId, getObjectType, getPhase, isAutoStartup, isRunning, start, stop, stop

Methods inherited from class org.springframework.beans.factory.config.AbstractFactoryBean

afterPropertiesSet, destroy, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingleton

Methods inherited from class java.lang.Object

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

Field Details

groupId

protected String groupId

Constructor Details

AbstractKafkaChannelSpec

public AbstractKafkaChannelSpec()

Method Details

id

public S id(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.