< Back
 

# Packages

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

  Definition Classes
    kafka
-  package utils

  Definition Classes
    manager
-  package logkafka81
  Definition Classes
    utils
-  package logkafka82
  Definition Classes
    utils
- Defaults
- LogConfig
- LogkafkaConfigErrors
-  package one10
  Definition Classes
    utils
-  package two00
  Definition Classes
    utils
-  package zero10
  Definition Classes
    utils
-  package zero11
  Definition Classes
    utils
-  package zero81
  Definition Classes
    utils
-  package zero82
  Definition Classes
    utils
-  package zero90
  Definition Classes
    utils

p

kafka.manager.utils

# logkafka82 

#### package logkafka82

 
Ordering

1. Alphabetic

Visibility

1. Public
2. All

### Type Members

1.  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

   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.

### Value Members

1.  object Defaults
2.  object LogConfig extends LogkafkaNewConfigs with Serializable
3.  object LogkafkaConfigErrors

### Ungrouped