Package

kafka.manager.utils

zero81

Permalink

package zero81

Visibility
  1. Public
  2. All

Type Members

  1. sealed trait ForceReassignmentCommand extends AnyRef

    Permalink

  2. case class LogConfig(segmentSize: Int = 1024*1024, segmentMs: Long = Long.MaxValue, flushInterval: Long = Long.MaxValue, flushMs: Long = Long.MaxValue, retentionSize: Long = Long.MaxValue, retentionMs: Long = Long.MaxValue, maxMessageSize: Int = Int.MaxValue, maxIndexSize: Int = 1024*1024, indexInterval: Int = 4096, fileDeleteDelayMs: Long = 60*1000, deleteRetentionMs: Long = 24 * 60 * 60 * 1000L, minCleanableRatio: Double = 0.5, compact: Boolean = false) extends Product with Serializable

    Permalink

    Copied from kafka 0.8.1.1 https://git-wip-us.apache.org/repos/asf?p=kafka.git;a=blob;f=core/src/main/scala/kafka/log/LogConfig.scala

  3. class ReassignPartitionCommand extends Logging

    Permalink

Value Members

  1. object ForceOnReplicationOutOfSync extends ForceReassignmentCommand with Product with Serializable

    Permalink

  2. object LogConfig extends TopicConfigs with Serializable

    Permalink

  3. object PreferredLeaderElectionErrors

    Permalink

  4. object PreferredReplicaLeaderElectionCommand extends Logging

    Permalink

    Borrowed from kafka 0.8.1.1, adapted to use curator framework https://git-wip-us.apache.org/repos/asf?p=kafka.git;a=blob;f=core/src/main/scala/kafka/admin/PreferredReplicaLeaderElectionCommand.scala

  5. object ReassignPartitionCommand

    Permalink

  6. object ReassignPartitionErrors

    Permalink

Ungrouped