Package org.springframework.pulsar.autoconfigure

Class PulsarAutoConfiguration

java.lang.Object

org.springframework.pulsar.autoconfigure.PulsarAutoConfiguration

@AutoConfiguration
@ConditionalOnClass(PulsarTemplate.class)
@EnableConfigurationProperties(PulsarProperties.class)
@Import(PulsarAnnotationDrivenConfiguration.class)
public class PulsarAutoConfiguration
extends Object

Auto-configuration for Apache Pulsar.

Author:

Soby Chacko, Chris Bono, Alexander Preuß

Constructor Summary

Constructors

Constructor	Description
PulsarAutoConfiguration(PulsarProperties properties)

Method Summary

Modifier and Type	Method	Description
PulsarProducerFactory<?>	cachingPulsarProducerFactory(org.apache.pulsar.client.api.PulsarClient pulsarClient, TopicResolver topicResolver)
PulsarAdministration	pulsarAdministration()
PulsarClientFactoryBean	pulsarClientFactoryBean()
PulsarConsumerFactory<?>	pulsarConsumerFactory(org.apache.pulsar.client.api.PulsarClient pulsarClient)
PulsarFunctionAdministration	pulsarFunctionAdministration(PulsarAdministration pulsarAdministration, ObjectProvider<PulsarFunction> pulsarFunctions, ObjectProvider<PulsarSink> pulsarSinks, ObjectProvider<PulsarSource> pulsarSources)
PulsarProducerFactory<?>	pulsarProducerFactory(org.apache.pulsar.client.api.PulsarClient pulsarClient, TopicResolver topicResolver)
PulsarReaderFactory<?>	pulsarReaderFactory(org.apache.pulsar.client.api.PulsarClient pulsarClient)
PulsarTemplate<?>	pulsarTemplate(PulsarProducerFactory<?> pulsarProducerFactory, ObjectProvider<org.apache.pulsar.client.api.interceptor.ProducerInterceptor> interceptorsProvider, SchemaResolver schemaResolver, TopicResolver topicResolver, ObjectProvider<io.micrometer.observation.ObservationRegistry> observationRegistryProvider, ObjectProvider<PulsarTemplateObservationConvention> observationConventionProvider)
DefaultSchemaResolver	schemaResolver(PulsarProperties pulsarProperties, Optional<SchemaResolver.SchemaResolverCustomizer<DefaultSchemaResolver>> schemaResolverCustomizer)
DefaultTopicResolver	topicResolver(PulsarProperties pulsarProperties)

Methods inherited from class java.lang.Object

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

Constructor Details

PulsarAutoConfiguration

public PulsarAutoConfiguration(PulsarProperties properties)

Method Details

pulsarClientFactoryBean

@Bean
@ConditionalOnMissingBean
public PulsarClientFactoryBean pulsarClientFactoryBean()

pulsarProducerFactory

@Bean
@ConditionalOnMissingBean
@ConditionalOnProperty(name="spring.pulsar.producer.cache.enabled",
                       havingValue="false")
public PulsarProducerFactory<?> pulsarProducerFactory(org.apache.pulsar.client.api.PulsarClient pulsarClient,
 TopicResolver topicResolver)

cachingPulsarProducerFactory

@Bean
@ConditionalOnMissingBean
@ConditionalOnClass(com.github.benmanes.caffeine.cache.Caffeine.class)
@ConditionalOnProperty(name="spring.pulsar.producer.cache.enabled",
                       havingValue="true",
                       matchIfMissing=true)
public PulsarProducerFactory<?> cachingPulsarProducerFactory(org.apache.pulsar.client.api.PulsarClient pulsarClient,
 TopicResolver topicResolver)

pulsarTemplate

@Bean
@ConditionalOnMissingBean
public PulsarTemplate<?> pulsarTemplate(PulsarProducerFactory<?> pulsarProducerFactory,
 ObjectProvider<org.apache.pulsar.client.api.interceptor.ProducerInterceptor> interceptorsProvider,
 SchemaResolver schemaResolver,
 TopicResolver topicResolver,
 ObjectProvider<io.micrometer.observation.ObservationRegistry> observationRegistryProvider,
 ObjectProvider<PulsarTemplateObservationConvention> observationConventionProvider)

schemaResolver

@Bean
@ConditionalOnMissingBean(SchemaResolver.class)
public DefaultSchemaResolver schemaResolver(PulsarProperties pulsarProperties,
 Optional<SchemaResolver.SchemaResolverCustomizer<DefaultSchemaResolver>> schemaResolverCustomizer)

topicResolver

@Bean
@ConditionalOnMissingBean(TopicResolver.class)
public DefaultTopicResolver topicResolver(PulsarProperties pulsarProperties)

pulsarConsumerFactory

@Bean
@ConditionalOnMissingBean
public PulsarConsumerFactory<?> pulsarConsumerFactory(org.apache.pulsar.client.api.PulsarClient pulsarClient)

pulsarAdministration

@Bean
@ConditionalOnMissingBean
public PulsarAdministration pulsarAdministration()

pulsarFunctionAdministration

@Bean
@ConditionalOnMissingBean
@ConditionalOnProperty(name="spring.pulsar.function.enabled",
                       havingValue="true",
                       matchIfMissing=true)
public PulsarFunctionAdministration pulsarFunctionAdministration(PulsarAdministration pulsarAdministration,
 ObjectProvider<PulsarFunction> pulsarFunctions,
 ObjectProvider<PulsarSink> pulsarSinks,
 ObjectProvider<PulsarSource> pulsarSources)

pulsarReaderFactory

@Bean
@ConditionalOnMissingBean
public PulsarReaderFactory<?> pulsarReaderFactory(org.apache.pulsar.client.api.PulsarClient pulsarClient)