Producer message delivery timeout not working?

[GianfrancoGGL]

Hi everyone,

I'm using the librdkafka 2.12.0 library and I'm trying to set the message delivery timeout sent by the producer to 30 seconds but I actually get a response after 5 minutes, I would like the delivery callback to be called even if there is no connection to the broker, I'm attaching the general configuration and the topic configuration, can anyone help me?

General configuration:

builtin.features = ssl,sasl,regex,lz4,sasl_gssapi,sasl_plain,sasl_scram,plugins,sasl_oauthbearer
client.id = GATEWAY-01-OPEN-PROTOCOL
client.software.name = librdkafka
metadata.broker.list = 192.168.56.131:9092
message.max.bytes = 1000000
message.copy.max.bytes = 65535
receive.message.max.bytes = 100000000
max.in.flight.requests.per.connection = 1000000
metadata.recovery.strategy = rebootstrap
metadata.recovery.rebootstrap.trigger.ms = 300000
metadata.request.timeout.ms = 1000
topic.metadata.refresh.interval.ms = 300000
metadata.max.age.ms = 900000
topic.metadata.refresh.fast.interval.ms = 100
topic.metadata.refresh.fast.cnt = 10
topic.metadata.refresh.sparse = true
topic.metadata.propagation.max.ms = 30000
debug =
socket.timeout.ms = 30000
socket.blocking.max.ms = 1000
socket.send.buffer.bytes = 0
socket.receive.buffer.bytes = 0
socket.keepalive.enable = false
socket.nagle.disable = true
socket.max.fails = 1
broker.address.ttl = 1000
broker.address.family = any
socket.connection.setup.timeout.ms = 30000
connections.max.idle.ms = 0
enable.sparse.connections = true
reconnect.backoff.jitter.ms = 0
reconnect.backoff.ms = 100
reconnect.backoff.max.ms = 10000
statistics.interval.ms = 0
enabled_events = 0
log_cb = 00007FF6E77A57FD
log_level = 6
log.queue = false
log.thread.name = true
enable.random.seed = true
log.connection.close = true
socket_cb = 00007FFA0A2324AF
open_cb = 00007FFA0A231951
opaque = 000001FDF9AACCD0
internal.termination.signal = 0
api.version.request = true
api.version.request.timeout.ms = 10000
api.version.fallback.ms = 0
broker.version.fallback = 0.10.0
allow.auto.create.topics = false
security.protocol = plaintext
ssl.ca.certificate.stores = Root
ssl.engine.id = dynamic
enable.ssl.certificate.verification = true
ssl.endpoint.identification.algorithm = https
sasl.mechanisms = GSSAPI
sasl.kerberos.service.name = kafka
sasl.kerberos.principal = kafkaclient
sasl.kerberos.kinit.cmd = kinit -R -t "%{sasl.kerberos.keytab}" -k %{sasl.kerberos.principal} || kinit -t "%{sasl.kerberos.keytab}" -k %{sasl.kerberos.principal}
sasl.kerberos.min.time.before.relogin = 60000
enable.sasl.oauthbearer.unsecure.jwt = false
enable_sasl_queue = false
sasl.oauthbearer.method = default
sasl.oauthbearer.grant.type = client_credentials
sasl.oauthbearer.assertion.algorithm = RS256
sasl.oauthbearer.assertion.claim.exp.seconds = 300
sasl.oauthbearer.assertion.claim.jti.include = false
sasl.oauthbearer.assertion.claim.nbf.seconds = 60
sasl.oauthbearer.metadata.authentication.type = none
test.mock.num.brokers = 0
test.mock.broker.rtt = 0
partition.assignment.strategy = range,roundrobin
session.timeout.ms = 45000
heartbeat.interval.ms = 3000
group.protocol.type = consumer
group.protocol = classic
coordinator.query.interval.ms = 600000
max.poll.interval.ms = 300000
enable.auto.commit = true
auto.commit.interval.ms = 5000
enable.auto.offset.store = true
queued.min.messages = 100000
queued.max.messages.kbytes = 65536
fetch.wait.max.ms = 500
fetch.queue.backoff.ms = 1000
fetch.message.max.bytes = 1048576
fetch.max.bytes = 52428800
fetch.min.bytes = 1
fetch.error.backoff.ms = 500
offset.store.method = broker
isolation.level = read_committed
enable.partition.eof = false
check.crcs = false
client.rack =
transaction.timeout.ms = 60000
enable.idempotence = false
enable.gapless.guarantee = false
queue.buffering.max.messages = 5000
queue.buffering.max.kbytes = 1048576
queue.buffering.max.ms = 10
message.send.max.retries = 3
retry.backoff.ms = 100
retry.backoff.max.ms = 1000
queue.buffering.backpressure.threshold = 1
compression.codec = none
batch.num.messages = 20
batch.size = 1000000
delivery.report.only.error = false
dr_msg_cb = 00007FF6E77B1A53
sticky.partitioning.linger.ms = 10
client.dns.lookup = use_all_dns_ips
enable.metrics.push = true

Topic configuration:

request.required.acks = -1
request.timeout.ms = 30000
message.timeout.ms = 30000
queuing.strategy = fifo
produce.offset.report = false
partitioner = consistent_random
compression.codec = inherit
compression.level = -1
auto.commit.enable = true
auto.commit.interval.ms = 60000
auto.offset.reset = largest
offset.store.path = .
offset.store.sync.interval.ms = -1
offset.store.method = broker
consume.callback.max.messages = 0

[GianfrancoGGL]

My bad, it's working, sorry!