From 16a7834e6d356d8ab442865c585d063552a9c393 Mon Sep 17 00:00:00 2001 From: Chia-Ping Tsai Date: Thu, 17 Sep 2020 11:23:56 +0800 Subject: [PATCH] MINOR: remove unused scala files from core module --- .../scala/kafka/common/ClientIdAndTopic.scala | 35 ------------------- .../common/NoEpochForPartitionException.scala | 25 ------------- 2 files changed, 60 deletions(-) delete mode 100644 core/src/main/scala/kafka/common/ClientIdAndTopic.scala delete mode 100644 core/src/main/scala/kafka/common/NoEpochForPartitionException.scala diff --git a/core/src/main/scala/kafka/common/ClientIdAndTopic.scala b/core/src/main/scala/kafka/common/ClientIdAndTopic.scala deleted file mode 100644 index 5825aad2c8d1a..0000000000000 --- a/core/src/main/scala/kafka/common/ClientIdAndTopic.scala +++ /dev/null @@ -1,35 +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 kafka.common - -/** - * Convenience case class since (clientId, topic) pairs are used in the creation - * of many Stats objects. - */ -trait ClientIdTopic { -} - -case class ClientIdAndTopic(clientId: String, topic: String) extends ClientIdTopic { - override def toString = "%s-%s".format(clientId, topic) -} - -case class ClientIdAllTopics(clientId: String) extends ClientIdTopic { - override def toString = "%s-%s".format(clientId, "AllTopics") -} - - diff --git a/core/src/main/scala/kafka/common/NoEpochForPartitionException.scala b/core/src/main/scala/kafka/common/NoEpochForPartitionException.scala deleted file mode 100644 index ef823f2fb58e7..0000000000000 --- a/core/src/main/scala/kafka/common/NoEpochForPartitionException.scala +++ /dev/null @@ -1,25 +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 kafka.common - -/** - * Thrown when a get epoch request is made for partition, but no epoch exists for that partition - */ -class NoEpochForPartitionException(message: String) extends RuntimeException(message) { - def this() = this(null) -} \ No newline at end of file