kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject git commit: kafka-1157; Clean up Per-topic Configuration from Kafka properties; patched by Guozhang Wang; reviewed by Jun Rao
Date Tue, 03 Dec 2013 05:54:57 GMT
Updated Branches:
  refs/heads/trunk 7c7951426 -> b638b0f34


kafka-1157; Clean up Per-topic Configuration from Kafka properties; patched by Guozhang Wang;
reviewed by Jun Rao


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/b638b0f3
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/b638b0f3
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/b638b0f3

Branch: refs/heads/trunk
Commit: b638b0f34623769e2efbcb7c2c36f7b742f6b690
Parents: 7c79514
Author: Guozhang Wang <guwang@linkedin.com>
Authored: Mon Dec 2 21:55:48 2013 -0800
Committer: Jun Rao <junrao@gmail.com>
Committed: Mon Dec 2 21:55:48 2013 -0800

----------------------------------------------------------------------
 core/src/main/scala/kafka/server/KafkaConfig.scala | 12 ------------
 1 file changed, 12 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/b638b0f3/core/src/main/scala/kafka/server/KafkaConfig.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/server/KafkaConfig.scala b/core/src/main/scala/kafka/server/KafkaConfig.scala
index b324344..8f9db10 100644
--- a/core/src/main/scala/kafka/server/KafkaConfig.scala
+++ b/core/src/main/scala/kafka/server/KafkaConfig.scala
@@ -104,27 +104,15 @@ class KafkaConfig private (val props: VerifiableProperties) extends
ZKConfig(pro
   /* the maximum size of a single log file */
   val logSegmentBytes = props.getIntInRange("log.segment.bytes", 1*1024*1024*1024, (Message.MinHeaderSize,
Int.MaxValue))
 
-  /* the maximum size of a single log file for some specific topic */
-  val logSegmentBytesPerTopicMap = props.getMap("log.segment.bytes.per.topic", _.toInt >
0).mapValues(_.toInt)
-
   /* the maximum time before a new log segment is rolled out */
   val logRollHours = props.getIntInRange("log.roll.hours", 24*7, (1, Int.MaxValue))
 
-  /* the number of hours before rolling out a new log segment for some specific topic */
-  val logRollHoursPerTopicMap = props.getMap("log.roll.hours.per.topic", _.toInt > 0).mapValues(_.toInt)
-
   /* the number of hours to keep a log file before deleting it */
   val logRetentionTimeMillis = getLogRetentionTimeMillis
 
-  /* the number of hours to keep a log file before deleting it for some specific topic*/
-  val logRetentionHoursPerTopicMap = props.getMap("log.retention.hours.per.topic", _.toInt
> 0).mapValues(_.toInt)
-
   /* the maximum size of the log before deleting it */
   val logRetentionBytes = props.getLong("log.retention.bytes", -1)
 
-  /* the maximum size of the log for some specific topic before deleting it */
-  val logRetentionBytesPerTopicMap = props.getMap("log.retention.bytes.per.topic", _.toLong
> 0).mapValues(_.toLong)
-  
   /* the frequency in minutes that the log cleaner checks whether any log is eligible for
deletion */
   val logCleanupIntervalMs = props.getLongInRange("log.retention.check.interval.ms", 5*60*1000,
(1, Long.MaxValue))
   


Mime
View raw message