kafka-test.conf

kafka {
  consumer {
    throttling {
      enabled = true
      interval = 1s
      limit = 100
    }
    alpakka = ${pekko.kafka.consumer}
    alpakka {
      poll-timeout = 100ms # overwrites default from reference.conf
      kafka-clients {
        default.key.serde = "org.apache.kafka.common.serialization.Serdes$StringSerde" # default:	org.apache.kafka.common.serialization.Serdes$ByteArraySerde
        default.value.serde = "org.apache.kafka.common.serialization.Serdes$StringSerde" # default:	org.apache.kafka.common.serialization.Serdes$ByteArraySerde
      }
    }
    metric-collecting-interval = 5s
    init-timeout-seconds = 3
  }
  producer {
    queue-size = 39
    parallelism = 3
    min-backoff = 3s
    max-backoff = 30s
    random-factor = 0.2
    init-timeout-seconds = 3

    alpakka = ${pekko.kafka.producer}
    alpakka {
      close-timeout = 10s # overwrites default from reference.conf
      kafka-clients {
        connections.max.idle.ms = 540000 # default: 540000 (9min)
        reconnect.backoff.max.ms = 10000 # default: 1000
        reconnect.backoff.ms = 500 # default: 50
      }
    }
  }
}