TridentKafkaConsumerTopology (Storm 2.7.1 API)

java.lang.Object
- org.apache.storm.kafka.trident.TridentKafkaConsumerTopology

public class TridentKafkaConsumerTopology
extends Object

Field Summary

Fields
Modifier and Type Field Description

protected static org.slf4j.Logger LOG

Constructor Summary

Constructors
Constructor Description

TridentKafkaConsumerTopology()

Method Summary

All Methods Static Methods Concrete Methods
Modifier and Type	Method	Description
`static StormTopology`	`newTopology(ITridentDataSource tridentSpout)`	Creates a new topology that prints inputs to stdout.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - LOG
```
protected static final org.slf4j.Logger LOG
```
- Constructor Detail
  - TridentKafkaConsumerTopology
```
public TridentKafkaConsumerTopology()
```
- Method Detail
  - newTopology
```
public static StormTopology newTopology(ITridentDataSource tridentSpout)
```
    Creates a new topology that prints inputs to stdout.
    
    Parameters:
    
    tridentSpout - The spout to use