Our configurations related to Akka were like:

akka.kafka.producer {

parallelism = 100

close-timeout = 60s

use-dispatcher = "akka.kafka.default-dispatcher"

eos-commit-interval = 100ms

kafka-clients {

}

}

akka.kafka.consumer {

poll-interval = 50ms

poll-timeout = 50ms

close-timeout = 20s

commit-timeout = 15s

commit-time-warning = 1s

commit-refresh-interval = infinite

use-dispatcher = "akka.kafka.default-dispatcher"

kafka-clients {

enable.auto.commit = true

}

wait-close-partition = 500ms

position-timeout = 5s

offset-for-times-timeout = 5s

metadata-request-timeout = 5s

partition.assignment.strategy = org.apache.kafka.clients.consumer.RoundRobinAssignor

}