How to get and set Lagom Kafka Consumer configuration?

Lagom Lagom Message Broker API
1

I’m using Lagom 1.6 and implements a topic.subscribe in a microservice implementation.
I would like to change the commit batching-size of this consumer but it doesn’t seems to change something. I tried to add this to my application.conf:

lagom.broker.kafka.client.consumer.offset-buffer = 1
lagom.broker.kafka.client.consumer.batching-size = 1
lagom.broker.kafka.client.consumer.batching-interval = 100 millis

according to Lagom documentation: https://www.lagomframework.com/documentation/1.6.x/scala/KafkaClient.html

Also I really need to print all parameters in order to know what parameters are used but I don’t know how to do it.

2

@domschoen

You can check if your configuration are being loaded if you debug your dependency inject configuration at the running time. Try this

class MySubcriber(config: Configuration) {

setUpMySubcriberConfigs()

def setUpMySubcriberConfigs() {
   val lookAtMyConfigs = config.get[Configuration]("lagom.broker.kafka.client.consumer")
  // debug point
   lookAtMyConfigs
}

}

Is not the smartest way to do that but you ill be able to see if the configs are loaded