Repository: kafka Updated Branches: refs/heads/trunk 4f8ad1561 -> a3bd99811
MINOR: remove no longer needed CommitType Author: Jason Gustafson <[email protected]> Reviewers: Ismael Juma, Guozhang Wang Closes #258 from hachikuji/delete-committype Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/a3bd9981 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/a3bd9981 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/a3bd9981 Branch: refs/heads/trunk Commit: a3bd99811c6ed7b30611ff0592e4ce7bc8537260 Parents: 4f8ad15 Author: Jason Gustafson <[email protected]> Authored: Fri Oct 2 15:09:28 2015 -0700 Committer: Guozhang Wang <[email protected]> Committed: Fri Oct 2 15:09:28 2015 -0700 ---------------------------------------------------------------------- .../apache/kafka/clients/consumer/CommitType.java | 17 ----------------- .../main/scala/kafka/tools/EndToEndLatency.scala | 2 +- .../integration/kafka/api/SSLConsumerTest.scala | 5 ----- 3 files changed, 1 insertion(+), 23 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/a3bd9981/clients/src/main/java/org/apache/kafka/clients/consumer/CommitType.java ---------------------------------------------------------------------- diff --git a/clients/src/main/java/org/apache/kafka/clients/consumer/CommitType.java b/clients/src/main/java/org/apache/kafka/clients/consumer/CommitType.java deleted file mode 100644 index 7548a9b..0000000 --- a/clients/src/main/java/org/apache/kafka/clients/consumer/CommitType.java +++ /dev/null @@ -1,17 +0,0 @@ -/** - * 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. - */ -package org.apache.kafka.clients.consumer; - -public enum CommitType { - SYNC, ASYNC -} http://git-wip-us.apache.org/repos/asf/kafka/blob/a3bd9981/core/src/main/scala/kafka/tools/EndToEndLatency.scala ---------------------------------------------------------------------- diff --git a/core/src/main/scala/kafka/tools/EndToEndLatency.scala b/core/src/main/scala/kafka/tools/EndToEndLatency.scala index eb2a75c..8197dfc 100755 --- a/core/src/main/scala/kafka/tools/EndToEndLatency.scala +++ b/core/src/main/scala/kafka/tools/EndToEndLatency.scala @@ -19,7 +19,7 @@ package kafka.tools import java.util.{Arrays, Properties} -import org.apache.kafka.clients.consumer.{CommitType, ConsumerConfig, KafkaConsumer} +import org.apache.kafka.clients.consumer.{ConsumerConfig, KafkaConsumer} import org.apache.kafka.clients.producer._ import org.apache.kafka.common.utils.Utils http://git-wip-us.apache.org/repos/asf/kafka/blob/a3bd9981/core/src/test/scala/integration/kafka/api/SSLConsumerTest.scala ---------------------------------------------------------------------- diff --git a/core/src/test/scala/integration/kafka/api/SSLConsumerTest.scala b/core/src/test/scala/integration/kafka/api/SSLConsumerTest.scala index b2fc057..2f72c78 100644 --- a/core/src/test/scala/integration/kafka/api/SSLConsumerTest.scala +++ b/core/src/test/scala/integration/kafka/api/SSLConsumerTest.scala @@ -19,15 +19,10 @@ import org.apache.kafka.clients.producer.ProducerConfig import org.apache.kafka.clients.producer.ProducerRecord import org.apache.kafka.clients.producer.KafkaProducer import org.apache.kafka.clients.consumer.Consumer -import org.apache.kafka.clients.consumer.ConsumerConfig import org.apache.kafka.clients.consumer.KafkaConsumer -import org.apache.kafka.clients.consumer.ConsumerRebalanceListener import org.apache.kafka.clients.consumer.ConsumerRecord import org.apache.kafka.clients.consumer.ConsumerConfig -import org.apache.kafka.clients.consumer.CommitType -import org.apache.kafka.common.serialization.ByteArrayDeserializer import org.apache.kafka.common.TopicPartition -import org.apache.kafka.clients.consumer.NoOffsetForPartitionException import kafka.integration.KafkaServerTestHarness import kafka.utils.{TestUtils, Logging}
