Package org.zalando.spring.boot.fahrschein.nakadi.config

Class FahrscheinNakadiConsumer

java.lang.Object
org.zalando.spring.boot.fahrschein.nakadi.config.FahrscheinNakadiConsumer
All Implemented Interfaces:
NakadiConsumer, MeterRegistryAware
public class FahrscheinNakadiConsumer extends Object implements NakadiConsumer, MeterRegistryAware

  • Constructor Details

    • FahrscheinNakadiConsumer

      public FahrscheinNakadiConsumer()

  • Method Details

    • getConsumerConfig

      public ConsumerConfig getConsumerConfig()
      Specified by:
      getConsumerConfig in interface NakadiConsumer

    • setMeterRegistry

      public void setMeterRegistry(io.micrometer.core.instrument.MeterRegistry meterRegistry)
      Specified by:
      setMeterRegistry in interface MeterRegistryAware

    • runnable

      public <Type> org.zalando.fahrschein.IORunnable runnable(NakadiListener<Type> listener) throws IOException
      Specified by:
      runnable in interface NakadiConsumer
      Throws:
      IOException

    • getMetricsCollector

      protected static org.zalando.fahrschein.MetricsCollector getMetricsCollector(ConsumerConfig consumerConfig, io.micrometer.core.instrument.MeterRegistry meterRegistry)

    • getBackoffStrategy

      protected static org.zalando.fahrschein.BackoffStrategy getBackoffStrategy(ConsumerConfig consumerConfig)

    • getStreamParameters

      protected org.zalando.fahrschein.StreamParameters getStreamParameters()