| Interface | Description |
|---|---|
| IInputTupleConverter<T> |
Input Tuple Converter interface.
|
| IOutputTupleConverter<T> |
Output Tuple Converter interface.
|
| Class | Description |
|---|---|
| AsyncKafkaProducer |
When writing to Kafka using the asynchronous API, in case of write error
it is best to close the producer and reinit a new one.
|
| AtLeastOnceFileOutput |
The "At least once" version of the FileBolt.
In case of a topology failure/restart, duplicated Tuples will be found. |
| JdbcHandle | |
| JsonKafkaOutput | |
| KafkaOutputBoltPartitioner |
The partitioner is in charge of telling the kafka producer to which partition
the next message should go to.
|
| LumberjackKafkaOutput | |
| OneByOneFileOutput |
The "Exactly once" version of the FileBolt.
A special variation of the FileBolt that creates a dedicated file batch object for each Tuple. |
Copyright © 2023. All rights reserved.