KafkaConsumerConfig
data class KafkaConsumerConfig(val applicationId: String = requiredConfigForKey("NAIS_APP_NAME"), val maxPollRecords: Int = 1, val autoOffsetReset: String = "earliest", val enableAutoCommit: Boolean = false, val brokers: String = requiredConfigForKey("KAFKA_BROKERS"), val ssl: SslConfig? = SslConfig(), val schemaRegistry: SchemaRegistryConfig? = SchemaRegistryConfig(), val compressionType: String = "snappy", val additionalProperties: Properties = Properties(), val keyDeserializer: Class<out Deserializer<*>> = StringDeserializer::class.java, val valueDeserializer: Class<out Deserializer<*>> = StringDeserializer::class.java)(source)
Constructors
Link copied to clipboard
constructor(applicationId: String = requiredConfigForKey("NAIS_APP_NAME"), maxPollRecords: Int = 1, autoOffsetReset: String = "earliest", enableAutoCommit: Boolean = false, brokers: String = requiredConfigForKey("KAFKA_BROKERS"), ssl: SslConfig? = SslConfig(), schemaRegistry: SchemaRegistryConfig? = SchemaRegistryConfig(), compressionType: String = "snappy", additionalProperties: Properties = Properties(), keyDeserializer: Class<out Deserializer<*>> = StringDeserializer::class.java, valueDeserializer: Class<out Deserializer<*>> = StringDeserializer::class.java)