14 lines
560 B
Scala
14 lines
560 B
Scala
package com.twitter.recos.user_user_graph
|
|
|
|
/**
|
|
* The class holds all the config parameters for kafka queue.
|
|
*/
|
|
object KafkaConfig {
|
|
// The size of the RecosHoseMessage array that is written to the concurrently linked queue
|
|
// Buffersize of 64 to keep throughput around 64 / (2K edgesPerSec / 150 kafka threads) = 6 seconds, which is lower
|
|
// than young gen gc cycle, 20 seconds. So that all the incoming messages will be gced in young gen instead of old gen.
|
|
val bufferSize = 64
|
|
|
|
println("KafkaConfig - bufferSize " + bufferSize)
|
|
}
|