KAFKA-2787: Refactor gradle build

checkstyle/checkstyle.xml

@@ -1,6 +1,6 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <!DOCTYPE module PUBLIC
-    "-//Puppy Crawl//DTD Check Configuration 1.3//EN" 
+    "-//Puppy Crawl//DTD Check Configuration 1.3//EN"
      "http://www.puppycrawl.com/dtds/configuration_1_3.dtd">
 <!--
 // Licensed to the Apache Software Foundation (ASF) under one or more
@@ -9,9 +9,9 @@
 // The ASF licenses this file to You 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.
@@ -67,7 +67,7 @@
 
     <!-- dependencies -->
     <module name="ImportControl">
-      <property name="file" value="${basedir}/checkstyle/import-control.xml"/>
+      <property name="file" value="${importControlFile}"/>
     </module>
 
     <!-- whitespace -->

checkstyle/import-control-core.xml

@@ -0,0 +1,71 @@
+<!DOCTYPE import-control PUBLIC
+"-//Puppy Crawl//DTD Import Control 1.1//EN"
+"http://www.puppycrawl.com/dtds/import_control_1_1.dtd">
+<!--
+// Licensed to the Apache Software Foundation (ASF) under one or more
+// contributor license agreements.  See the NOTICE file distributed with
+// this work for additional information regarding copyright ownership.
+// The ASF licenses this file to You 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.
+-->
+
+<import-control pkg="kafka">
+
+  <!-- THINK HARD ABOUT THE LAYERING OF THE PROJECT BEFORE CHANGING THIS FILE -->
+
+  <!-- common library dependencies -->
+  <allow pkg="java" />
+  <allow pkg="scala" />
+  <allow pkg="javax.management" />
+  <allow pkg="org.slf4j" />
+  <allow pkg="org.junit" />
+  <allow pkg="org.easymock" />
+  <allow pkg="org.powermock" />
+  <allow pkg="java.security" />
+  <allow pkg="javax.net.ssl" />
+  <allow pkg="javax.security" />
+  <allow pkg="org.ietf.jgss" />
+
+  <allow pkg="kafka.common" />
+  <allow pkg="kafka.utils" />
+  <allow pkg="kafka.serializer" />
+  <allow pkg="org.apache.kafka.common" />
+
+  <subpackage name="javaapi">
+    <subpackage name="consumer">
+      <allow pkg="kafka.consumer" />
+    </subpackage>
+
+    <subpackage name="message">
+      <allow pkg="kafka.message" />
+    </subpackage>
+
+    <subpackage name="producer">
+      <allow pkg="kafka.producer" />
+    </subpackage>
+  </subpackage>
+
+  <subpackage name="tools">
+    <allow pkg="kafka.javaapi" />
+    <allow pkg="kafka.producer" />
+    <allow pkg="kafka.consumer" />
+    <allow pkg="joptsimple" />
+  </subpackage>
+
+  <subpackage name="examples">
+    <allow pkg="org.apache.kafka.clients" />
+    <allow pkg="kafka.api" />
+    <allow pkg="kafka.javaapi" />
+    <allow pkg="kafka.message" />
+  </subpackage>
+
+</import-control>

checkstyle/import-control.xml

@@ -212,3 +212,5 @@
   </subpackage>
 
 </import-control>
+
+

connect/tools/src/main/java/org/apache/kafka/connect/tools/VerifiableSinkTask.java

@@ -29,7 +29,6 @@
 import java.util.Collection;
 import java.util.HashMap;
 import java.util.Map;
-import java.util.Properties;
 
 /**
  * Counterpart to {@link VerifiableSourceTask} that consumes records and logs information about each to stdout. This

core/src/main/scala/kafka/javaapi/consumer/ConsumerConnector.java

@@ -17,72 +17,72 @@
 
 package kafka.javaapi.consumer;
 
-
-import java.util.List;
-import java.util.Map;
-
 import kafka.common.OffsetAndMetadata;
 import kafka.common.TopicAndPartition;
 import kafka.consumer.KafkaStream;
 import kafka.consumer.TopicFilter;
 import kafka.serializer.Decoder;
 
+import java.util.List;
+import java.util.Map;
+
 public interface ConsumerConnector {
-  /**
-   *  Create a list of MessageStreams of type T for each topic.
-   *
-   *  @param topicCountMap  a map of (topic, #streams) pair
-   *  @param keyDecoder a decoder that decodes the message key
-   *  @param valueDecoder a decoder that decodes the message itself
-   *  @return a map of (topic, list of  KafkaStream) pairs.
-   *          The number of items in the list is #streams. Each stream supports
-   *          an iterator over message/metadata pairs.
-   */
-  public <K,V> Map<String, List<KafkaStream<K,V>>> 
-    createMessageStreams(Map<String, Integer> topicCountMap, Decoder<K> keyDecoder, Decoder<V> valueDecoder);
-
-  public Map<String, List<KafkaStream<byte[], byte[]>>> createMessageStreams(Map<String, Integer> topicCountMap);
+    /**
+     *  Create a list of MessageStreams of type T for each topic.
+     *
+     *  @param topicCountMap  a map of (topic, #streams) pair
+     *  @param keyDecoder a decoder that decodes the message key
+     *  @param valueDecoder a decoder that decodes the message itself
+     *  @return a map of (topic, list of  KafkaStream) pairs.
+     *          The number of items in the list is #streams. Each stream supports
+     *          an iterator over message/metadata pairs.
+     */
+    public <K, V> Map<String, List<KafkaStream<K, V>>>
+        createMessageStreams(Map<String, Integer> topicCountMap, Decoder<K> keyDecoder, Decoder<V> valueDecoder);
+
+    public Map<String, List<KafkaStream<byte[], byte[]>>> createMessageStreams(Map<String, Integer> topicCountMap);
+
+    /**
+     *  Create a list of MessageAndTopicStreams containing messages of type T.
+     *
+     *  @param topicFilter a TopicFilter that specifies which topics to
+     *                    subscribe to (encapsulates a whitelist or a blacklist).
+     *  @param numStreams the number of message streams to return.
+     *  @param keyDecoder a decoder that decodes the message key
+     *  @param valueDecoder a decoder that decodes the message itself
+     *  @return a list of KafkaStream. Each stream supports an
+     *          iterator over its MessageAndMetadata elements.
+     */
+    public <K, V> List<KafkaStream<K, V>>
+        createMessageStreamsByFilter(TopicFilter topicFilter, int numStreams, Decoder<K> keyDecoder, Decoder<V> valueDecoder);
+
+    public List<KafkaStream<byte[], byte[]>> createMessageStreamsByFilter(TopicFilter topicFilter, int numStreams);
+
+    public List<KafkaStream<byte[], byte[]>> createMessageStreamsByFilter(TopicFilter topicFilter);
 
-  /**
-   *  Create a list of MessageAndTopicStreams containing messages of type T.
-   *
-   *  @param topicFilter a TopicFilter that specifies which topics to
-   *                    subscribe to (encapsulates a whitelist or a blacklist).
-   *  @param numStreams the number of message streams to return.
-   *  @param keyDecoder a decoder that decodes the message key
-   *  @param valueDecoder a decoder that decodes the message itself
-   *  @return a list of KafkaStream. Each stream supports an
-   *          iterator over its MessageAndMetadata elements.
-   */
-  public <K,V> List<KafkaStream<K,V>> 
-    createMessageStreamsByFilter(TopicFilter topicFilter, int numStreams, Decoder<K> keyDecoder, Decoder<V> valueDecoder);
-
-  public List<KafkaStream<byte[], byte[]>> createMessageStreamsByFilter(TopicFilter topicFilter, int numStreams);
-
-  public List<KafkaStream<byte[], byte[]>> createMessageStreamsByFilter(TopicFilter topicFilter);
+    /**
+     *  Commit the offsets of all broker partitions connected by this connector.
+     */
+    public void commitOffsets();
 
-  /**
-   *  Commit the offsets of all broker partitions connected by this connector.
-   */
-  public void commitOffsets();
-  public void commitOffsets(boolean retryOnFailure);
+    public void commitOffsets(boolean retryOnFailure);
 
-  /**
-   *  Commit offsets using the provided offsets map
-   *
-   *  @param offsetsToCommit a map containing the offset to commit for each partition.
-   *  @param retryOnFailure enable retries on the offset commit if it fails.
-   */
-  public void commitOffsets(Map<TopicAndPartition, OffsetAndMetadata> offsetsToCommit, boolean retryOnFailure);
+    /**
+     *  Commit offsets using the provided offsets map
+     *
+     *  @param offsetsToCommit a map containing the offset to commit for each partition.
+     *  @param retryOnFailure enable retries on the offset commit if it fails.
+     */
+    public void commitOffsets(Map<TopicAndPartition, OffsetAndMetadata> offsetsToCommit, boolean retryOnFailure);
 
-  /**
-   * Wire in a consumer rebalance listener to be executed when consumer rebalance occurs.
-   * @param listener The consumer rebalance listener to wire in
-   */
-  public void setConsumerRebalanceListener(ConsumerRebalanceListener listener);
+    /**
+     * Wire in a consumer rebalance listener to be executed when consumer rebalance occurs.
+     * @param listener The consumer rebalance listener to wire in
+     */
+    public void setConsumerRebalanceListener(ConsumerRebalanceListener listener);
 
-  /**
-   *  Shut down the connector
-   */
-  public void shutdown();
+    /**
+     *  Shut down the connector
+     */
+    public void shutdown();
 }