Change KafkaConsumer Properties

Gatling (Open-Source)
1

Gatling version: 3.12.0
Gatling flavor: java kotlin scala javascript typescript
Gatling build tool: maven gradle sbt bundle npm
gatling-kafka-plugin: 0.12.1

Does anyone know how to change the Consumer Config properties? I did make the changes but somehow the values are not taken into account when starting the consumer.

 public KafkaProtocolBuilderNew kafkaProtocolBuilder() {
        return kafka().requestReply()
            .producerSettings(
               Map.of(
                   ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, kafkaBaseConfig.getBootstrapServers()
               )
            )

            .consumeSettings(
                Map.of(
                    ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, kafkaBaseConfig.getBootstrapServers(),
                    ConsumerConfig.GROUP_ID_CONFIG, "XYZ",
                    ConsumerConfig.CLIENT_ID_CONFIG, "ABC"
                )
            ).withDefaultTimeout();
2

Hello,

Sorry but here is only a place for official Gatling components.

As you’re using a third party plugin, please reach out to its author on his own channel, most likely his bugtracker on GithHub.

Regards