From 234373a663692ee2e42ba6267b3a65e7647cd376 Mon Sep 17 00:00:00 2001 From: Jason Gustafson Date: Mon, 28 Sep 2015 17:22:54 -0700 Subject: [PATCH] MINOR: remove no longer needed CommitType --- .../kafka/clients/consumer/CommitType.java | 17 ----------------- .../scala/kafka/tools/EndToEndLatency.scala | 2 +- .../integration/kafka/api/SSLConsumerTest.scala | 5 ----- 3 files changed, 1 insertion(+), 23 deletions(-) delete mode 100644 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 7548a9ba0163a..0000000000000 --- 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 -} diff --git a/core/src/main/scala/kafka/tools/EndToEndLatency.scala b/core/src/main/scala/kafka/tools/EndToEndLatency.scala index eb2a75c50a8f0..8197dfc03b6d1 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 diff --git a/core/src/test/scala/integration/kafka/api/SSLConsumerTest.scala b/core/src/test/scala/integration/kafka/api/SSLConsumerTest.scala index b2fc0575bf962..2f72c782be4df 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}