Package io.quarkus.kafka.streams.deployment

Class KafkaStreamsProcessor

java.lang.Object
io.quarkus.kafka.streams.deployment.KafkaStreamsProcessor
class KafkaStreamsProcessor extends Object

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    static final String
    DEFAULT_PARTITION_GROUPER
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    KafkaStreamsProcessor()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    (package private) void
    addHealthChecks(KafkaStreamsBuildTimeConfig buildTimeConfig, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.smallrye.health.deployment.spi.HealthBuildItem> healthChecks)
     
    (package private) void
    build(io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.nativeimage.ReflectiveClassBuildItem> reflectiveClasses, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.nativeimage.JniRuntimeAccessBuildItem> jniRuntimeAccessibleClasses, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.nativeimage.RuntimeInitializedClassBuildItem> reinitialized, io.quarkus.deployment.builditem.LaunchModeBuildItem launchMode)
     
    (package private) io.quarkus.deployment.builditem.FeatureBuildItem
    feature()
     
    (package private) io.quarkus.deployment.builditem.NativeImageFeatureBuildItem
    kafkaStreamsFeature()
     
    (package private) void
    loadRocksDb(io.quarkus.kafka.streams.runtime.KafkaStreamsRecorder recorder)
     
    (package private) void
    processBuildTimeConfig(io.quarkus.kafka.streams.runtime.KafkaStreamsRecorder recorder, io.quarkus.deployment.builditem.LaunchModeBuildItem launchMode, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.arc.deployment.SyntheticBeanBuildItem> syntheticBeanBuildItemBuildProducer, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.arc.deployment.AdditionalBeanBuildItem> additionalBeans)
     
    (package private) io.quarkus.deployment.builditem.ModuleEnableNativeAccessBuildItem
    rocksDbEnableNativeAccess()
     

    Methods inherited from class java.lang.Object

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

  • Field Details

  • Constructor Details

    • KafkaStreamsProcessor

      KafkaStreamsProcessor()

  • Method Details

    • feature

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

    • build

      void build(io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.nativeimage.ReflectiveClassBuildItem> reflectiveClasses, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.nativeimage.JniRuntimeAccessBuildItem> jniRuntimeAccessibleClasses, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.nativeimage.RuntimeInitializedClassBuildItem> reinitialized, io.quarkus.deployment.builditem.LaunchModeBuildItem launchMode)

    • processBuildTimeConfig

      void processBuildTimeConfig(io.quarkus.kafka.streams.runtime.KafkaStreamsRecorder recorder, io.quarkus.deployment.builditem.LaunchModeBuildItem launchMode, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.arc.deployment.SyntheticBeanBuildItem> syntheticBeanBuildItemBuildProducer, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.arc.deployment.AdditionalBeanBuildItem> additionalBeans)

    • loadRocksDb

      void loadRocksDb(io.quarkus.kafka.streams.runtime.KafkaStreamsRecorder recorder)

    • addHealthChecks

      void addHealthChecks(KafkaStreamsBuildTimeConfig buildTimeConfig, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.smallrye.health.deployment.spi.HealthBuildItem> healthChecks)

    • kafkaStreamsFeature

      io.quarkus.deployment.builditem.NativeImageFeatureBuildItem kafkaStreamsFeature()

    • rocksDbEnableNativeAccess

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