KafkaStandaloneGenerator (Flink : Examples : Streaming 1.18.1-cp3 API)

java.lang.Object
- org.apache.flink.streaming.examples.statemachine.generator.StandaloneThreadedGenerator
- - org.apache.flink.streaming.examples.statemachine.kafka.KafkaStandaloneGenerator

public class KafkaStandaloneGenerator
extends StandaloneThreadedGenerator

A generator that pushes the data into Kafka.

- Field Summary
  
  Fields
  Modifier and Type Field Description
  
  static String BROKER_ADDRESS
  
  static int NUM_PARTITIONS
  
  static String TOPIC
- Constructor Summary
  
  Constructors
  Constructor Description
  
  KafkaStandaloneGenerator()
- Method Summary
  
  All Methods Static Methods Concrete Methods
  Modifier and Type Method Description
  
  static void main(String[] args)
  Entry point to the kafka data producer.
  - Methods inherited from class org.apache.flink.streaming.examples.statemachine.generator.StandaloneThreadedGenerator
    runGenerator
  - Methods inherited from class java.lang.Object
    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - BROKER_ADDRESS
```
public static final String BROKER_ADDRESS
```
    See Also:
    
    Constant Field Values
  - TOPIC
```
public static final String TOPIC
```
    See Also:
    
    Constant Field Values
  - NUM_PARTITIONS
```
public static final int NUM_PARTITIONS
```
    See Also:
    
    Constant Field Values
- Constructor Detail
  - KafkaStandaloneGenerator
```
public KafkaStandaloneGenerator()
```
- Method Detail
  - main
```
public static void main(String[] args)
                 throws Exception
```
    Entry point to the kafka data producer.
    
    Throws:
    
    Exception