Class | Description |
---|---|
FixedPartitioner<T> |
A partitioner ensuring that each internal Flink partition ends up in one Kafka partition.
|
KafkaPartitioner<T> |
It contains a open() method which is called on each parallel instance.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.