Skip to content

Commit

Permalink
Typo fix for addTopics and doWithAdmin @SInCE
Browse files Browse the repository at this point in the history
- 2.1.6 not 2.1
  • Loading branch information
astubbs authored and garyrussell committed Jun 13, 2018
1 parent 91e0f62 commit 8cfd24b
Showing 1 changed file with 3 additions and 3 deletions.
Expand Up @@ -266,7 +266,7 @@ private void createKafkaTopics(Set<String> topics) {
/**
* Add topics to the existing broker(s) using the configured number of partitions.
* @param topics the topics.
* @since 2.1
* @since 2.1.6
*/
public void addTopics(String... topics) {
HashSet<String> set = new HashSet<>(Arrays.asList(topics));
Expand All @@ -275,10 +275,10 @@ public void addTopics(String... topics) {
}

/**
* Create an {@link AdminClient} invoke the callback and reliable close the
* Create an {@link AdminClient}; invoke the callback and reliably close the
* admin.
* @param callback the callback.
* @since 2.1
* @since 2.1.6
*/
public void doWithAdmin(java.util.function.Consumer<AdminClient> callback) {
Map<String, Object> adminConfigs = new HashMap<>();
Expand Down

0 comments on commit 8cfd24b

Please sign in to comment.