We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 25b73fb commit 5adca19Copy full SHA for 5adca19
lib/kaffe/config/producer.ex
@@ -48,6 +48,7 @@ defmodule Kaffe.Config.Producer do
48
[
49
auto_start_producers: true,
50
allow_topic_auto_creation: false,
51
+ extra_sock_opts: [keepalive: config_get(:keepalive, false)],
52
default_producer_config: [
53
required_acks: config_get(:required_acks, -1),
54
ack_timeout: config_get(:ack_timeout, 1000),
0 commit comments