KafkaRunner (openwifi-base 2.7.0 API)

java.lang.Object
- com.facebook.openwifi.cloudsdk.kafka.KafkaRunner

All Implemented Interfaces:: Runnable

public class KafkaRunner
extends Object
implements Runnable

Kafka runner.

- Constructor Summary
  
  Constructors
  Constructor Description
  
  KafkaRunner(UCentralKafkaConsumer consumer, UCentralKafkaProducer producer)
  Run with the given consumer/producer instances.
- Method Summary
  
  All Methods Instance Methods Concrete Methods
  Modifier and Type Method Description
  
  void run()
  
  void shutdown()
  Shutdown hook which can be called from a separate thread.
  - Methods inherited from class java.lang.Object
    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - KafkaRunner
```
public KafkaRunner(UCentralKafkaConsumer consumer,
                   UCentralKafkaProducer producer)
```
    Run with the given consumer/producer instances.
- Method Detail
  - run
```
public void run()
```
    Specified by:
    
    run in interface Runnable
  - shutdown
```
public void shutdown()
```
    Shutdown hook which can be called from a separate thread.