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 a Kafka topic.

Since:

5.4

Author:

Gary Russell

Field Summary

Fields

Modifier and Type	Field and 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.context.SmartLifecycle

DEFAULT_PHASE

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

OBJECT_TYPE_ATTRIBUTE

Constructor Summary

Constructors

Constructor and Description
AbstractKafkaChannelSpec()

Method Summary

Modifier and Type	Method and 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 Detail

groupId

protected String groupId

Constructor Detail

AbstractKafkaChannelSpec

public AbstractKafkaChannelSpec()

Method Detail

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.