Package io.quarkus.kafka.client.deployment

Class KafkaProcessor

java.lang.Object
io.quarkus.kafka.client.deployment.KafkaProcessor
public class KafkaProcessor extends Object

  • Nested Class Summary

    Nested Classes
    Modifier and Type
    Class
    Description
    static final class 
    KafkaProcessor.HasSnappy
     

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    (package private) static final Class<?>[]
    BUILT_INS
     
    (package private) static final org.jboss.jandex.DotName
    OBJECT_MAPPER
     
    (package private) static final org.jboss.jandex.DotName
    PARTITION_ASSIGNER
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    KafkaProcessor()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    (package private) io.quarkus.smallrye.health.deployment.spi.HealthBuildItem
    addHealthCheck(KafkaBuildTimeConfig buildTimeConfig)
     
    (package private) void
    addSaslProvidersToNativeImage(io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.nativeimage.NativeImageSecurityProviderBuildItem> additionalProviders)
     
    void
    build(KafkaBuildTimeConfig config, io.quarkus.deployment.pkg.builditem.CurateOutcomeBuildItem curateOutcomeBuildItem, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.ConfigDescriptionBuildItem> configDescBuildItems, io.quarkus.deployment.builditem.CombinedIndexBuildItem indexBuildItem, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.nativeimage.ReflectiveClassBuildItem> reflectiveClass, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.nativeimage.ServiceProviderBuildItem> serviceProviders, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.nativeimage.NativeImageProxyDefinitionBuildItem> proxies, io.quarkus.deployment.Capabilities capabilities, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.arc.deployment.UnremovableBeanBuildItem> beans, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.ExtensionSslNativeSupportBuildItem> sslNativeSupport)
     
    (package private) void
    checkBoostrapServers(io.quarkus.kafka.client.runtime.KafkaRecorder recorder, io.quarkus.deployment.Capabilities capabilities)
     
    (package private) void
    contributeClassesToIndex(io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.AdditionalIndexedClassesBuildItem> additionalIndexedClasses, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.IndexDependencyBuildItem> indexDependency, io.quarkus.deployment.Capabilities capabilities)
     
    (package private) io.quarkus.arc.deployment.UnremovableBeanBuildItem
    ensureJsonParserAvailable()
     
    (package private) io.quarkus.deployment.builditem.FeatureBuildItem
    feature()
     
    void
    handleSnappyInNative(io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.nativeimage.ReflectiveClassBuildItem> reflectiveClass, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.NativeImageFeatureBuildItem> feature)
     
    io.quarkus.arc.deployment.AdditionalBeanBuildItem
    kafkaAdmin()
     
    io.quarkus.arc.deployment.AdditionalBeanBuildItem
    kafkaClientBeans()
     
    (package private) void
    loadSnappyIfEnabled(io.quarkus.deployment.builditem.LaunchModeBuildItem launch, io.quarkus.kafka.client.runtime.SnappyRecorder recorder, KafkaBuildTimeConfig config)
     
    (package private) void
    logging(io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.LogCategoryBuildItem> log)
     
    (package private) io.quarkus.deployment.builditem.nativeimage.NativeImageConfigBuildItem
    nativeImageConfiguration()
     
    (package private) void
    registerServiceBinding(io.quarkus.deployment.Capabilities capabilities, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.nativeimage.ServiceProviderBuildItem> serviceProvider)
     
    (package private) void
    relaxSaslElytron(io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.RunTimeConfigurationDefaultBuildItem> config)
     
    io.quarkus.arc.deployment.AdditionalBeanBuildItem
    runtimeConfig()
     
    (package private) io.quarkus.deployment.builditem.nativeimage.RuntimeInitializedPackageBuildItem
    runtimeInitializedClasses()
     
    (package private) void
    silenceUnwantedConfigLogs(io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.logging.LogCleanupFilterBuildItem> logCleanupFilters)
     
    (package private) io.quarkus.deployment.builditem.ModuleEnableNativeAccessBuildItem
    snappyEnableNativeAccess()
     
    void
    withSasl(io.quarkus.deployment.builditem.CombinedIndexBuildItem index, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.nativeimage.ReflectiveClassBuildItem> reflectiveClass, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.nativeimage.NativeImageResourceBundleBuildItem> resources, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.nativeimage.ReflectiveClassConditionBuildItem> reflectiveClassCondition, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.ExtensionSslNativeSupportBuildItem> sslNativeSupport)
     

    Methods inherited from class java.lang.Object

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

  • Field Details

    • BUILT_INS

      static final Class<?>[] BUILT_INS

    • OBJECT_MAPPER

      static final org.jboss.jandex.DotName OBJECT_MAPPER

    • PARTITION_ASSIGNER

      static final org.jboss.jandex.DotName PARTITION_ASSIGNER

  • Constructor Details

    • KafkaProcessor

      public KafkaProcessor()

  • Method Details

    • feature

      io.quarkus.deployment.builditem.FeatureBuildItem feature()

    • logging

      void logging(io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.LogCategoryBuildItem> log)

    • silenceUnwantedConfigLogs

      void silenceUnwantedConfigLogs(io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.logging.LogCleanupFilterBuildItem> logCleanupFilters)

    • addSaslProvidersToNativeImage

      void addSaslProvidersToNativeImage(io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.nativeimage.NativeImageSecurityProviderBuildItem> additionalProviders)

    • contributeClassesToIndex

      void contributeClassesToIndex(io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.AdditionalIndexedClassesBuildItem> additionalIndexedClasses, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.IndexDependencyBuildItem> indexDependency, io.quarkus.deployment.Capabilities capabilities)

    • relaxSaslElytron

      void relaxSaslElytron(io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.RunTimeConfigurationDefaultBuildItem> config)

    • build

      public void build(KafkaBuildTimeConfig config, io.quarkus.deployment.pkg.builditem.CurateOutcomeBuildItem curateOutcomeBuildItem, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.ConfigDescriptionBuildItem> configDescBuildItems, io.quarkus.deployment.builditem.CombinedIndexBuildItem indexBuildItem, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.nativeimage.ReflectiveClassBuildItem> reflectiveClass, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.nativeimage.ServiceProviderBuildItem> serviceProviders, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.nativeimage.NativeImageProxyDefinitionBuildItem> proxies, io.quarkus.deployment.Capabilities capabilities, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.arc.deployment.UnremovableBeanBuildItem> beans, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.ExtensionSslNativeSupportBuildItem> sslNativeSupport)

    • handleSnappyInNative

      public void handleSnappyInNative(io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.nativeimage.ReflectiveClassBuildItem> reflectiveClass, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.NativeImageFeatureBuildItem> feature)

    • loadSnappyIfEnabled

      void loadSnappyIfEnabled(io.quarkus.deployment.builditem.LaunchModeBuildItem launch, io.quarkus.kafka.client.runtime.SnappyRecorder recorder, KafkaBuildTimeConfig config)

    • snappyEnableNativeAccess

      io.quarkus.deployment.builditem.ModuleEnableNativeAccessBuildItem snappyEnableNativeAccess()

    • checkBoostrapServers

      void checkBoostrapServers(io.quarkus.kafka.client.runtime.KafkaRecorder recorder, io.quarkus.deployment.Capabilities capabilities)

    • runtimeConfig

      public io.quarkus.arc.deployment.AdditionalBeanBuildItem runtimeConfig()

    • withSasl

      public void withSasl(io.quarkus.deployment.builditem.CombinedIndexBuildItem index, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.nativeimage.ReflectiveClassBuildItem> reflectiveClass, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.nativeimage.NativeImageResourceBundleBuildItem> resources, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.nativeimage.ReflectiveClassConditionBuildItem> reflectiveClassCondition, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.ExtensionSslNativeSupportBuildItem> sslNativeSupport)

    • addHealthCheck

      io.quarkus.smallrye.health.deployment.spi.HealthBuildItem addHealthCheck(KafkaBuildTimeConfig buildTimeConfig)

    • ensureJsonParserAvailable

      io.quarkus.arc.deployment.UnremovableBeanBuildItem ensureJsonParserAvailable()

    • nativeImageConfiguration

      io.quarkus.deployment.builditem.nativeimage.NativeImageConfigBuildItem nativeImageConfiguration()

    • registerServiceBinding

      void registerServiceBinding(io.quarkus.deployment.Capabilities capabilities, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.nativeimage.ServiceProviderBuildItem> serviceProvider)

    • kafkaAdmin

      public io.quarkus.arc.deployment.AdditionalBeanBuildItem kafkaAdmin()

    • runtimeInitializedClasses

      io.quarkus.deployment.builditem.nativeimage.RuntimeInitializedPackageBuildItem runtimeInitializedClasses()

    • kafkaClientBeans

      public io.quarkus.arc.deployment.AdditionalBeanBuildItem kafkaClientBeans()