< Back
 

# Packages

-  package root
  Definition Classes
    root
-  package kafka
  Definition Classes
    root
-  package manager

  Definition Classes
    kafka
-  package utils

  Definition Classes
    manager
-  package logkafka82
  Definition Classes
    utils
- Defaults
- LogConfig
- LogkafkaConfigErrors

c

kafka.manager.utils.logkafka82

# LogConfig 

###
Companion object LogConfig

#### case class LogConfig(valid: Boolean = Defaults.Valid, followLast: Boolean = Defaults.FollowLast, readFromHead: Boolean = Defaults.ReadFromHead, batchSize: Long = Defaults.BatchSize, lineDelimiter: Int = Defaults.LineDelimiter, removeDelimiter: Boolean = Defaults.RemoveDelimiter, topic: String = Defaults.Topic, key: String = Defaults.Key, partition: Int = Defaults.Partition, compressionCodec: String = Defaults.CompressionCodec, requiredAcks: Int = Defaults.RequiredAcks, messageTimeoutMs: Long = Defaults.MessageTimeoutMs, regexFilterPattern: String = Defaults.RegexFilterPattern, laggingMaxBytes: Long = Defaults.LaggingMaxBytes, rotateLaggingMaxSec: Long = Defaults.RotateLaggingMaxSec) extends Product with Serializable

Configuration settings for a log

valid

  Enable now or not

followLast

  If set to "false", when restarting logkafka process, the log_path formatted with current time will be collect; If set to "true", when restarting logkafka process, the last collecting file will be collected continually

readFromHead

  If set to "false", the first file will be collected from tail; If set to "true", the first file will be collected from head

batchSize

  The batch size of messages to be sent

lineDelimiter

  Delimiter of log file lines

removeDelimiter

  Remove delimiter or not when collecting log file lines

topic

  The topic of messages to be sent

key

  The key of messages to be sent

partition

  The partition of messages to be sent. -1 : random n(>=0): partition n

compressionCodec

  Optional compression method of messages: none, gzip, snappy

requiredAcks

  Number of required acks

messageTimeoutMs

  Local message timeout. This value is only enforced locally and limits the time a produced message waits for successful delivery. A time of 0 is infinite.

regexFilterPattern

  The messages matching this pattern will be dropped.

Linear Supertypes
Serializable, Serializable, Product, Equals, AnyRef, Any
 
Ordering

1. Alphabetic
2. By Inheritance

Inherited

1. LogConfig
2. Serializable
3. Serializable
4. Product
5. Equals
6. AnyRef
7. Any

1. Hide All
2. Show All

Visibility

1. Public
2. All

### Instance Constructors

1.  new LogConfig(valid: Boolean = Defaults.Valid, followLast: Boolean = Defaults.FollowLast, readFromHead: Boolean = Defaults.ReadFromHead, batchSize: Long = Defaults.BatchSize, lineDelimiter: Int = Defaults.LineDelimiter, removeDelimiter: Boolean = Defaults.RemoveDelimiter, topic: String = Defaults.Topic, key: String = Defaults.Key, partition: Int = Defaults.Partition, compressionCodec: String = Defaults.CompressionCodec, requiredAcks: Int = Defaults.RequiredAcks, messageTimeoutMs: Long = Defaults.MessageTimeoutMs, regexFilterPattern: String = Defaults.RegexFilterPattern, laggingMaxBytes: Long = Defaults.LaggingMaxBytes, rotateLaggingMaxSec: Long = Defaults.RotateLaggingMaxSec)

   valid

     Enable now or not

   followLast

     If set to "false", when restarting logkafka process, the log_path formatted with current time will be collect; If set to "true", when restarting logkafka process, the last collecting file will be collected continually

   readFromHead

     If set to "false", the first file will be collected from tail; If set to "true", the first file will be collected from head

   batchSize

     The batch size of messages to be sent

   lineDelimiter

     Delimiter of log file lines

   removeDelimiter

     Remove delimiter or not when collecting log file lines

   topic

     The topic of messages to be sent

   key

     The key of messages to be sent

   partition

     The partition of messages to be sent. -1 : random n(>=0): partition n

   compressionCodec

     Optional compression method of messages: none, gzip, snappy

   requiredAcks

     Number of required acks

   messageTimeoutMs

     Local message timeout. This value is only enforced locally and limits the time a produced message waits for successful delivery. A time of 0 is infinite.

   regexFilterPattern

     The messages matching this pattern will be dropped.

### Value Members

1.  final def !=(arg0: Any): Boolean
   Definition Classes
     AnyRef → Any
2.  final def ##(): Int
   Definition Classes
     AnyRef → Any
3.  final def ==(arg0: Any): Boolean
   Definition Classes
     AnyRef → Any
4.  def abs(n: Int): Int

   Get the absolute value of the given number.

   Get the absolute value of the given number. If the number is Int.MinValue return 0. This is different from java.lang.Math.abs or scala.math.abs in that they return Int.MinValue (!).

5.  final def asInstanceOf[T0]: T0
   Definition Classes
     Any
6.  val batchSize: Long
7.  def clone(): AnyRef
   Attributes
     protected[java.lang]
   Definition Classes
     AnyRef
   Annotations
     @native() @throws( ... )
8.  val compressionCodec: String
9.  final def eq(arg0: AnyRef): Boolean
   Definition Classes
     AnyRef
10.  def finalize(): Unit
    Attributes
      protected[java.lang]
    Definition Classes
      AnyRef
    Annotations
      @throws( classOf[java.lang.Throwable] )
11.  val followLast: Boolean
12.  final def getClass(): Class[_]
    Definition Classes
      AnyRef → Any
    Annotations
      @native()
13.  final def isInstanceOf[T0]: Boolean
    Definition Classes
      Any
14.  val key: String
15.  val laggingMaxBytes: Long
16.  val lineDelimiter: Int
17.  val messageTimeoutMs: Long
18.  final def ne(arg0: AnyRef): Boolean
    Definition Classes
      AnyRef
19.  final def notify(): Unit
    Definition Classes
      AnyRef
    Annotations
      @native()
20.  final def notifyAll(): Unit
    Definition Classes
      AnyRef
    Annotations
      @native()
21.  val partition: Int
22.  val readFromHead: Boolean
23.  val regexFilterPattern: String
24.  val removeDelimiter: Boolean
25.  val requiredAcks: Int
26.  val rotateLaggingMaxSec: Long
27.  final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
      AnyRef
28.  def toProps: Properties
29.  val topic: String
30.  val valid: Boolean
31.  final def wait(): Unit
    Definition Classes
      AnyRef
    Annotations
      @throws( ... )
32.  final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
      AnyRef
    Annotations
      @throws( ... )
33.  final def wait(arg0: Long): Unit
    Definition Classes
      AnyRef
    Annotations
      @native() @throws( ... )

### Inherited from Serializable

### Inherited from Product

### Inherited from Equals

### Inherited from AnyRef

### Inherited from Any

### Ungrouped