Skip to content

Commit

Permalink
Makes default for fetch_max_wait_duration to 5s
Browse files Browse the repository at this point in the history
this is the franz client's default
  • Loading branch information
hendoxc committed May 9, 2024
1 parent fd85943 commit f5c819d
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion internal/impl/kafka/input_kafka_franz.go
Original file line number Diff line number Diff line change
Expand Up @@ -91,7 +91,7 @@ Finally, it's also possible to specify an explicit offset to consume from by add
Advanced()).
Field(service.NewDurationField("fetch_max_wait_duration").
Description("Determines how long in for the broker to wait until it has enough data to send before responding").
Default(time.Duration.Milliseconds(500)).
Default(time.Duration.Seconds(5)).
Advanced()).
Field(service.NewIntField("max_partition_fetch_bytes").
Description("Determines the maximum amount of data to receive from a single partition in a single fetch request").
Expand Down

0 comments on commit f5c819d

Please sign in to comment.