Hierarchy For Package io.eventuate.messaging.kafka.basic.consumer

Class Hierarchy

• java.lang.Object
  • io.eventuate.messaging.kafka.basic.consumer.BackPressureActions
  • io.eventuate.messaging.kafka.basic.consumer.BackPressureConfig
  • io.eventuate.messaging.kafka.basic.consumer.BackPressureManager
  • io.eventuate.messaging.kafka.basic.consumer.BackPressureManagerNormalState (implements io.eventuate.messaging.kafka.basic.consumer.BackPressureManagerState)
  • io.eventuate.messaging.kafka.basic.consumer.BackPressureManagerPausedState (implements io.eventuate.messaging.kafka.basic.consumer.BackPressureManagerState)
  • io.eventuate.messaging.kafka.basic.consumer.BackPressureManagerStateAndActions
  • io.eventuate.messaging.kafka.basic.consumer.ConsumerPropertiesFactory
  • io.eventuate.messaging.kafka.basic.consumer.DefaultKafkaConsumerFactory (implements io.eventuate.messaging.kafka.basic.consumer.KafkaConsumerFactory)
  • io.eventuate.messaging.kafka.basic.consumer.DefaultKafkaMessageConsumer (implements io.eventuate.messaging.kafka.basic.consumer.KafkaMessageConsumer)
  • io.eventuate.messaging.kafka.basic.consumer.EventuateKafkaConsumer
  • io.eventuate.messaging.kafka.basic.consumer.EventuateKafkaConsumerConfigurationProperties
  • io.eventuate.messaging.kafka.basic.consumer.KafkaMessageProcessor
  • io.eventuate.messaging.kafka.basic.consumer.OffsetTracker
  • java.lang.Throwable (implements java.io.Serializable)
    • java.lang.Exception
      • java.lang.RuntimeException
        • io.eventuate.messaging.kafka.basic.consumer.KafkaMessageProcessorFailedException
  • io.eventuate.messaging.kafka.basic.consumer.TopicPartitionOffsets

Interface Hierarchy

• io.eventuate.messaging.kafka.basic.consumer.BackPressureManagerState
• java.util.function.BiFunction<T,U,R>
  • io.eventuate.messaging.kafka.basic.consumer.EventuateKafkaConsumerMessageHandler
• io.eventuate.messaging.kafka.basic.consumer.ConsumerCallbacks
• io.eventuate.messaging.kafka.basic.consumer.KafkaConsumerFactory
• io.eventuate.messaging.kafka.basic.consumer.KafkaMessageConsumer
• io.eventuate.messaging.kafka.basic.consumer.MessageConsumerBacklog

Enum Class Hierarchy

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.lang.constant.Constable, java.io.Serializable)
    • io.eventuate.messaging.kafka.basic.consumer.EventuateKafkaConsumerState