KafkaSplit(String, String, String, String, Optional, Optional, int, long, long, HostAddress) |  | 0% | | n/a | 1 | 1 | 12 | 12 | 1 | 1 |
toString() |  | 0% | | n/a | 1 | 1 | 12 | 12 | 1 | 1 |
getPreferredNodes(NodeProvider) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getConnectorId() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getStart() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getEnd() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getTopicName() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getKeyDataFormat() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getMessageDataFormat() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getKeyDataSchemaContents() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getMessageDataSchemaContents() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getPartitionId() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getLeader() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getNodeSelectionStrategy() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getInfo() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |