// Path: src/main/java/com/homeadvisor/kafdrop/config/ZookeeperProperties.java
// public class ZookeeperProperties
// {
//    public static final Pattern CONNECT_SEPARATOR = Pattern.compile("\\s*,\\s*");
//    @NotBlank
//    private String connect;
// 
//    private int sessionTimeoutMillis = (int) TimeUnit.SECONDS.toMillis(5);
//    private int connectTimeoutMillis = (int) TimeUnit.SECONDS.toMillis(15);
// 
//    private int retryMillis = (int) TimeUnit.SECONDS.toMillis(5);
//    private int maxRetries = Integer.MAX_VALUE;
// 
// 
//    public String getConnect()
//    {
//       return connect;
//    }
// 
//    public void setConnect(String connect)
//    {
//       this.connect = connect;
//    }
// 
//    public List<String> getConnectList()
//    {
//       return CONNECT_SEPARATOR.splitAsStream(this.connect)
//          .map(String::trim)
//          .filter(s -> s.length() > 0)
//          .collect(Collectors.toList());
//    }
// 
//    public int getRetryMillis()
//    {
//       return retryMillis;
//    }
// 
//    public void setRetryMillis(int retryMillis)
//    {
//       this.retryMillis = retryMillis;
//    }
// 
//    public int getMaxRetries()
//    {
//       return maxRetries;
//    }
// 
//    public void setMaxRetries(int maxRetries)
//    {
//       this.maxRetries = maxRetries;
//    }
// 
//    public int getSessionTimeoutMillis()
//    {
//       return sessionTimeoutMillis;
//    }
// 
//    public void setSessionTimeoutMillis(int sessionTimeoutMillis)
//    {
//       this.sessionTimeoutMillis = sessionTimeoutMillis;
//    }
// 
//    public int getConnectTimeoutMillis()
//    {
//       return connectTimeoutMillis;
//    }
// 
//    public void setConnectTimeoutMillis(int connectTimeoutMillis)
//    {
//       this.connectTimeoutMillis = connectTimeoutMillis;
//    }
// }


import com.homeadvisor.kafdrop.config.ZookeeperProperties;
import org.hibernate.validator.constraints.NotBlank;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.stereotype.Component;
import javax.validation.constraints.Min;
/*
 * Copyright 2017 HomeAdvisor, Inc.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 * http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 *
 *
 */

package com.homeadvisor.kafdrop.service;



@Component
@ConfigurationProperties(prefix = "kafdrop.monitor")
public class CuratorKafkaMonitorProperties
{
   private String clientId = "Kafdrop";

   @Min(1)
   private int threadPoolSize = 10;

   private RetryProperties retry = new RetryProperties();

   @NotBlank
   private String kafkaVersion = "0.8.2.2";

// Path: src/main/java/com/homeadvisor/kafdrop/config/ZookeeperProperties.java
// public class ZookeeperProperties
// {
//    public static final Pattern CONNECT_SEPARATOR = Pattern.compile("\\s*,\\s*");
//    @NotBlank
//    private String connect;
// 
//    private int sessionTimeoutMillis = (int) TimeUnit.SECONDS.toMillis(5);
//    private int connectTimeoutMillis = (int) TimeUnit.SECONDS.toMillis(15);
// 
//    private int retryMillis = (int) TimeUnit.SECONDS.toMillis(5);
//    private int maxRetries = Integer.MAX_VALUE;
// 
// 
//    public String getConnect()
//    {
//       return connect;
//    }
// 
//    public void setConnect(String connect)
//    {
//       this.connect = connect;
//    }
// 
//    public List<String> getConnectList()
//    {
//       return CONNECT_SEPARATOR.splitAsStream(this.connect)
//          .map(String::trim)
//          .filter(s -> s.length() > 0)
//          .collect(Collectors.toList());
//    }
// 
//    public int getRetryMillis()
//    {
//       return retryMillis;
//    }
// 
//    public void setRetryMillis(int retryMillis)
//    {
//       this.retryMillis = retryMillis;
//    }
// 
//    public int getMaxRetries()
//    {
//       return maxRetries;
//    }
// 
//    public void setMaxRetries(int maxRetries)
//    {
//       this.maxRetries = maxRetries;
//    }
// 
//    public int getSessionTimeoutMillis()
//    {
//       return sessionTimeoutMillis;
//    }
// 
//    public void setSessionTimeoutMillis(int sessionTimeoutMillis)
//    {
//       this.sessionTimeoutMillis = sessionTimeoutMillis;
//    }
// 
//    public int getConnectTimeoutMillis()
//    {
//       return connectTimeoutMillis;
//    }
// 
//    public void setConnectTimeoutMillis(int connectTimeoutMillis)
//    {
//       this.connectTimeoutMillis = connectTimeoutMillis;
//    }
// }


// Path: src/main/java/com/homeadvisor/kafdrop/service/CuratorKafkaMonitorProperties.java
import com.homeadvisor.kafdrop.config.ZookeeperProperties;
import org.hibernate.validator.constraints.NotBlank;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.stereotype.Component;
import javax.validation.constraints.Min;

/*
 * Copyright 2017 HomeAdvisor, Inc.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 * http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 *
 *
 */

package com.homeadvisor.kafdrop.service;



@Component
@ConfigurationProperties(prefix = "kafdrop.monitor")
public class CuratorKafkaMonitorProperties
{
   private String clientId = "Kafdrop";

   @Min(1)
   private int threadPoolSize = 10;

   private RetryProperties retry = new RetryProperties();

   @NotBlank
   private String kafkaVersion = "0.8.2.2";

   private ZookeeperProperties zookeeper = new ZookeeperProperties();