Package energy.eddie.outbound.kafka

Class KafkaOutboundConnector

java.lang.Object
energy.eddie.outbound.kafka.KafkaOutboundConnector
@SpringBootApplication @EnableKafka public class KafkaOutboundConnector extends Object

  • Constructor Details

    • KafkaOutboundConnector

      public KafkaOutboundConnector()

  • Method Details

    • kafkaPropertiesMap

      @Bean(name="kafkaPropertiesMap") @ConfigurationProperties(prefix="kafka") public Map<String,String> kafkaPropertiesMap()

    • serde

      @Bean public MessageSerde serde(@Value("${outbound-connector.kafka.format:json}") String format) throws SerdeInitializationException
      Throws:
      SerdeInitializationException

    • consumerFactory

      @Bean public org.springframework.kafka.core.ConsumerFactory<String,energy.eddie.cim.v0_82.pmd.PermissionEnvelope> consumerFactory(@Qualifier("kafkaPropertiesMap") Map<String,String> kafkaProperties, MessageSerde serde)

    • permissionEnvelopeListenerContainerFactory

      @Bean public org.springframework.kafka.config.KafkaListenerContainerFactory<org.springframework.kafka.listener.ConcurrentMessageListenerContainer<String,energy.eddie.cim.v0_82.pmd.PermissionEnvelope>> permissionEnvelopeListenerContainerFactory(org.springframework.kafka.core.ConsumerFactory<String,energy.eddie.cim.v0_82.pmd.PermissionEnvelope> consumerFactory)

    • rtrEnvelopeConsumerFactory

      @Bean public org.springframework.kafka.core.ConsumerFactory<String,energy.eddie.cim.v0_91_08.RTREnvelope> rtrEnvelopeConsumerFactory(@Qualifier("kafkaPropertiesMap") Map<String,String> kafkaProperties, MessageSerde serde)

    • rtrEnvelopeListenerContainerFactory

      @Bean public org.springframework.kafka.config.KafkaListenerContainerFactory<org.springframework.kafka.listener.ConcurrentMessageListenerContainer<String,energy.eddie.cim.v0_91_08.RTREnvelope>> rtrEnvelopeListenerContainerFactory(org.springframework.kafka.core.ConsumerFactory<String,energy.eddie.cim.v0_91_08.RTREnvelope> consumerFactory)

    • topicConfiguration

      @Bean public TopicConfiguration topicConfiguration(@Value("${outbound-connector.kafka.eddie-id}") String eddieId)

    • terminationTopic

      @Bean public org.apache.kafka.clients.admin.NewTopic terminationTopic(TopicConfiguration config)

    • retransmissionTopic

      @Bean public org.apache.kafka.clients.admin.NewTopic retransmissionTopic(TopicConfiguration config)

    • producerFactory

      @Bean public org.springframework.kafka.core.ProducerFactory<String,Object> producerFactory(@Qualifier("kafkaPropertiesMap") Map<String,String> kafkaProperties, MessageSerde serde)

    • kafkaTemplate

      @Bean public org.springframework.kafka.core.KafkaTemplate<String,Object> kafkaTemplate(org.springframework.kafka.core.ProducerFactory<String,Object> producerFactory)