Skip to content

Commit 4082a59

Browse files
committed
Made API reflect the uniqueness of kafka topics.
1 parent 624f3f6 commit 4082a59

File tree

1 file changed

+4
-3
lines changed

1 file changed

+4
-3
lines changed

src/main/java/com/hivemq/extensions/kafka/api/services/KafkaTopicService.java

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -2,17 +2,18 @@
22

33
import com.hivemq.extension.sdk.api.annotations.NotNull;
44

5-
import java.util.List;
5+
import java.util.Map;
6+
import java.util.Set;
67

78
public interface KafkaTopicService {
89

910
@NotNull KafkaTopicState getKafkaTopicState(@NotNull String topic);
1011

11-
@NotNull List<@NotNull KafkaTopicState> getKafkaTopicStates(@NotNull List<@NotNull String> topics);
12+
@NotNull Map<String, @NotNull KafkaTopicState> getKafkaTopicStates(@NotNull Set<@NotNull String> topics);
1213

1314
@NotNull KafkaTopicState createKafkaTopic(@NotNull String topic);
1415

15-
@NotNull List<@NotNull KafkaTopicState> createKafkaTopics(@NotNull List<@NotNull String> topics);
16+
@NotNull Map<String, @NotNull KafkaTopicState> createKafkaTopics(@NotNull Set<@NotNull String> topics);
1617

1718
enum KafkaTopicState {
1819
FAILURE, EXISTS, CREATED, MISSING,

0 commit comments

Comments
 (0)