Mailing-List: contact jira-help@kafka.apache.org; run by ezmlm
Precedence: bulk
Reply-To: jira@kafka.apache.org
Date: Sat, 8 Jul 2017 19:03:01 +0000 (UTC)
From: "Dmitry Minkovsky (JIRA)" <jira@apache.org>
To: jira@kafka.apache.org
Message-ID: <JIRA.13085720.1499540551000.200618.1499540581289@Atlassian.JIRA>
In-Reply-To: <JIRA.13085720.1499540551000@Atlassian.JIRA>
References: <JIRA.13085720.1499540551000@Atlassian.JIRA> <JIRA.13085720.1499540551240@jira-lw-us.apache.org>
Subject: [jira] [Updated] (KAFKA-5573) kaka-clients 0.11.0.0
 AdminClient#createTopics() does not set configs
MIME-Version: 1.0
Content-Type: text/plain; charset=utf-8
Content-Transfer-Encoding: 7bit
archived-at: Sat, 08 Jul 2017 19:03:17 -0000


     [ https://issues.apache.org/jira/browse/KAFKA-5573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Dmitry Minkovsky updated KAFKA-5573:
------------------------------------
    Summary: kaka-clients 0.11.0.0 AdminClient#createTopics() does not set configs  (was: kaka-clients 0.11.0.0 AdminClient#createTopics does not set configs)

> kaka-clients 0.11.0.0 AdminClient#createTopics() does not set configs
> ---------------------------------------------------------------------
>
>                 Key: KAFKA-5573
>                 URL: https://issues.apache.org/jira/browse/KAFKA-5573
>             Project: Kafka
>          Issue Type: Bug
>          Components: clients
>    Affects Versions: 0.11.0.0
>            Reporter: Dmitry Minkovsky
>
> I am creating topics like
> ```
>    private void createTopics(String[] topics, Map<String, String> config) {
>         log.info("creating topics: {} with config: {}", names, config);
>         CreateTopicsResult result = admin.createTopics(
>           Arrays
>             .stream(topics)
>             .map(topic -> new NewTopic(topic, partitions, replication))
>             .collect(Collectors.toList())
>         );
>         for (Map.Entry<String, KafkaFuture<Void>> entry : result.values().entrySet()) {
>             try {
>                 entry.getValue().get();
>                 log.info("topic {} created", entry.getKey());
>             } catch (InterruptedException | ExecutionException e) {
>                 if (Throwables.getRootCause(e) instanceof TopicExistsException) {
>                     log.info("topic {} existed", entry.getKey());
>                 }
>             }
>         }
>     }
> ```
> where I call this function like 
> ```
> Map<String, String> config = new HashMap<>();
> config.put("cleanup.policy", "compact");
> createTopics(new String[]{"topic"}, config);
> ```
> However, when I inspect the topic with 
>     ./kafka-configs.sh --zookeeper localhost:2181 --entity-type topics --entity-name topic --describe
> or 
>     ./kafka-topics.sh --zookeeper localhost:2181 --describe --topic topic
> there are no configs.


--
This message was sent by Atlassian JIRA
(v6.4.14#64029)