Skip to content

Commit c4bf579

Browse files
astubbsgaryrussell
authored andcommitted
Typo fix for addTopics and doWithAdmin @SInCE
- 2.1.6 not 2.1
1 parent c731e61 commit c4bf579

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

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

+3-3
Original file line numberDiff line numberDiff line change
@@ -265,7 +265,7 @@ private void createKafkaTopics(Set<String> topics) {
265265
/**
266266
* Add topics to the existing broker(s) using the configured number of partitions.
267267
* @param topics the topics.
268-
* @since 2.1
268+
* @since 2.1.6
269269
*/
270270
public void addTopics(String... topics) {
271271
HashSet<String> set = new HashSet<>(Arrays.asList(topics));
@@ -274,10 +274,10 @@ public void addTopics(String... topics) {
274274
}
275275

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

0 commit comments

Comments
 (0)