Class KafkaChannelParser

All Implemented Interfaces:
BeanDefinitionParser

public class KafkaChannelParser extends AbstractChannelParser
Parser for a channel backed by an Apache Kafka topic.
Since:
5.4
Author:
Gary Russell
  • Constructor Details

    • KafkaChannelParser

      public KafkaChannelParser()
  • Method Details

    • buildBeanDefinition

      protected BeanDefinitionBuilder buildBeanDefinition(Element element, ParserContext parserContext)
      Description copied from class: AbstractChannelParser
      Subclasses must implement this method to create the bean definition. The class must be defined, and any implementation-specific constructor arguments or properties should be configured. This base class will configure the interceptors including the 'datatype' interceptor if the 'datatype' attribute is defined on the channel element.
      Specified by:
      buildBeanDefinition in class AbstractChannelParser
      Parameters:
      element - The element.
      parserContext - The parser context.
      Returns:
      The bean definition builder.