KafkaConsumerConfig

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)(source)