Skip to content

Commit 8cfd24b

Browse files
astubbsgaryrussell
authored andcommitted
Typo fix for addTopics and doWithAdmin @SInCE
- 2.1.6 not 2.1
1 parent 91e0f62 commit 8cfd24b

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

spring-kafka-test/src/main/java/org/springframework/kafka/test/rule/KafkaEmbedded.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -266,7 +266,7 @@ private void createKafkaTopics(Set<String> topics) {
266266
/**
267267
* Add topics to the existing broker(s) using the configured number of partitions.
268268
* @param topics the topics.
269-
* @since 2.1
269+
* @since 2.1.6
270270
*/
271271
public void addTopics(String... topics) {
272272
HashSet<String> set = new HashSet<>(Arrays.asList(topics));
@@ -275,10 +275,10 @@ public void addTopics(String... topics) {
275275
}
276276

277277
/**
278-
* Create an {@link AdminClient} invoke the callback and reliable close the
278+
* Create an {@link AdminClient}; invoke the callback and reliably close the
279279
* admin.
280280
* @param callback the callback.
281-
* @since 2.1
281+
* @since 2.1.6
282282
*/
283283
public void doWithAdmin(java.util.function.Consumer<AdminClient> callback) {
284284
Map<String, Object> adminConfigs = new HashMap<>();

0 commit comments

Comments
 (0)