diff --git a/src/main/java/io/strimzi/kafka/bridge/KafkaBridgeAdmin.java b/src/main/java/io/strimzi/kafka/bridge/KafkaBridgeAdmin.java index e438c2e3..fe8db844 100644 --- a/src/main/java/io/strimzi/kafka/bridge/KafkaBridgeAdmin.java +++ b/src/main/java/io/strimzi/kafka/bridge/KafkaBridgeAdmin.java @@ -90,6 +90,8 @@ public CompletionStage> listTopics() { * Creates a topic with given name * * @param topicName topic name to create + * @param partitions number of partitions + * @param replicationFactor replication factor * @return a CompletionStage Void */ public CompletionStage createTopic(String topicName, int partitions, short replicationFactor) {