Skip to content

Commit

Permalink
Address style issues for PR
Browse files Browse the repository at this point in the history
  • Loading branch information
Daniel Woodlins committed Nov 7, 2017
1 parent d1cc661 commit 4de4b97
Show file tree
Hide file tree
Showing 3 changed files with 5 additions and 5 deletions.
2 changes: 1 addition & 1 deletion CONFIGURATION.md
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,7 @@ socket.receive.buffer.bytes | * | 0 .. 100000000 | 0
socket.keepalive.enable | * | true, false | false | Enable TCP keep-alives (SO_KEEPALIVE) on broker sockets <br>*Type: boolean*
socket.nagle.disable | * | true, false | false | Disable the Nagle algorithm (TCP_NODELAY). <br>*Type: boolean*
socket.max.fails | * | 0 .. 1000000 | 3 | Disconnect from broker when this number of send failures (e.g., timed out requests) is reached. Disable with 0. NOTE: The connection is automatically re-established. <br>*Type: integer*
broker.address.ttl | * | 0 .. 86400000 | 60000 | How long to cache the broker address resolving results (milliseconds). <br>*Type: integer*
broker.address.ttl | * | 0 .. 86400000 | 1000 | How long to cache the broker address resolving results (milliseconds). <br>*Type: integer*
broker.address.family | * | any, v4, v6 | any | Allowed broker IP address families: any, v4, v6 <br>*Type: enum value*
reconnect.backoff.jitter.ms | * | 0 .. 3600000 | 500 | Throttle broker reconnection attempts by this value +-50%. <br>*Type: integer*
statistics.interval.ms | * | 0 .. 86400000 | 0 | librdkafka statistics emit interval. The application also needs to register a stats callback using `rd_kafka_conf_set_stats_cb()`. The granularity is 1000ms. A value of 0 disables statistics. <br>*Type: integer*
Expand Down
6 changes: 3 additions & 3 deletions src/rdkafka_broker.c
Original file line number Diff line number Diff line change
Expand Up @@ -623,9 +623,9 @@ static int rd_kafka_broker_resolve (rd_kafka_broker_t *rkb) {
"Failed to resolve '%s': %s",
rkb->rkb_nodename, errstr);
return -1;
} else {
rkb->rkb_t_rsal_last = rd_clock();
}
} else {
rkb->rkb_t_rsal_last = rd_clock();
}
}

return 0;
Expand Down
2 changes: 1 addition & 1 deletion src/rdkafka_conf.c
Original file line number Diff line number Diff line change
Expand Up @@ -284,7 +284,7 @@ static const struct rd_kafka_property rd_kafka_properties[] = {
_RK(broker_addr_ttl),
"How long to cache the broker address resolving "
"results (milliseconds).",
0, 86400*1000, 1000 },
0, 86400*1000, 1*1000 },
{ _RK_GLOBAL, "broker.address.family", _RK_C_S2I,
_RK(broker_addr_family),
"Allowed broker IP address families: any, v4, v6",
Expand Down

0 comments on commit 4de4b97

Please sign in to comment.