Interface | Description |
---|---|
TopicRouter<IN> |
The router for choosing the desired topic to write the Flink records.
|
Class | Description |
---|---|
KeyHashTopicRouter<IN> |
If you choose the
TopicRoutingMode.MESSAGE_KEY_HASH policy, we would use this
implementation. |
RoundRobinTopicRouter<IN> |
If you choose the
TopicRoutingMode.ROUND_ROBIN policy, we would use this implementation. |
Enum | Description |
---|---|
MessageKeyHash |
Predefined the available hash function for routing the message.
|
TopicRoutingMode |
The routing policy for choosing the desired topic by the given message.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.