Class KafkaTransporter.KafkaPoller

java.lang.Object
services.moleculer.transporter.KafkaTransporter.KafkaPoller
All Implemented Interfaces:
Runnable
Enclosing class:
KafkaTransporter
protected static class KafkaTransporter.KafkaPoller extends Object implements Runnable

  • Field Details

    • UNSUBSCRIBED

      protected static final int UNSUBSCRIBED
      See Also:

    • SUBSCRIBED

      protected static final int SUBSCRIBED
      See Also:

    • STOPPING

      protected static final int STOPPING
      See Also:

    • consumer

      protected org.apache.kafka.clients.consumer.KafkaConsumer<byte[],byte[]> consumer

    • transporter

      protected final KafkaTransporter transporter

    • status

      protected final AtomicInteger status

    • firstError

      protected static boolean firstError

    • subscriptions

      protected HashSet<String> subscriptions

  • Constructor Details

  • Method Details

    • run

      public void run()
      Specified by:
      run in interface Runnable

    • subscribe

      protected void subscribe(String channel)

    • stop

      protected void stop()