[
https://issues.apache.org/jira/browse/KAFKA-5573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-5573:
---------------------------------
Fix Version/s: (was: 1.0.0)
> 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)
