LogConfig

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

Instance Constructors

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

final def !=(arg0: Any): Boolean

Definition Classes
AnyRef → Any
final def ##(): Int

Definition Classes
AnyRef → Any
final def ==(arg0: Any): Boolean

Definition Classes
AnyRef → Any
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 (!).
final def asInstanceOf[T0]: T0

Definition Classes
Any
val batchSize: Long

The batch size of messages to be sent
def clone(): AnyRef

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( ... )
val compressionCodec: String

Optional compression method of messages: none, gzip, snappy
final def eq(arg0: AnyRef): Boolean

Definition Classes
AnyRef
def finalize(): Unit

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( classOf[java.lang.Throwable] )
val followLast: Boolean

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
final def getClass(): Class[_]

Definition Classes
AnyRef → Any
final def isInstanceOf[T0]: Boolean

Definition Classes
Any
val key: String

The key of messages to be sent
val laggingMaxBytes: Long
val lineDelimiter: Int

Delimiter of log file lines
val messageTimeoutMs: Long

Local message timeout.
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.
final def ne(arg0: AnyRef): Boolean

Definition Classes
AnyRef
final def notify(): Unit

Definition Classes
AnyRef
final def notifyAll(): Unit

Definition Classes
AnyRef
val partition: Int

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

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

The messages matching this pattern will be dropped.
val removeDelimiter: Boolean

Remove delimiter or not when collecting log file lines
val requiredAcks: Int

Number of required acks
val rotateLaggingMaxSec: Long
final def synchronized[T0](arg0: ⇒ T0): T0

Definition Classes
AnyRef
def toProps: Properties
val topic: String

The topic of messages to be sent
val valid: Boolean

Enable now or not
final def wait(): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long, arg1: Int): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )

Related Docs: object LogConfig | package logkafka81

Instance Constructors

Value Members

final def !=(arg0: Any): Boolean

final def ##(): Int

final def ==(arg0: Any): Boolean

def abs(n: Int): Int

final def asInstanceOf[T0]: T0

val batchSize: Long

def clone(): AnyRef

val compressionCodec: String

final def eq(arg0: AnyRef): Boolean

def finalize(): Unit

val followLast: Boolean

final def getClass(): Class[_]

final def isInstanceOf[T0]: Boolean

val key: String

val laggingMaxBytes: Long

val lineDelimiter: Int

val messageTimeoutMs: Long

final def ne(arg0: AnyRef): Boolean

final def notify(): Unit

final def notifyAll(): Unit

val partition: Int

val readFromHead: Boolean

val regexFilterPattern: String

val removeDelimiter: Boolean

val requiredAcks: Int

val rotateLaggingMaxSec: Long

final def synchronized[T0](arg0: ⇒ T0): T0

def toProps: Properties

val topic: String

val valid: Boolean

final def wait(): Unit

final def wait(arg0: Long, arg1: Int): Unit

final def wait(arg0: Long): Unit

Inherited from Serializable

Inherited from Serializable

Inherited from Product

Inherited from Equals

Inherited from AnyRef

Inherited from Any

Ungrouped