Skip to content

Commit

Permalink
Update to librdkafka v0.11.3
Browse files Browse the repository at this point in the history
  • Loading branch information
Silviu Caragea committed Dec 14, 2017
1 parent d87ca04 commit 2f8c1dc
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
4 changes: 2 additions & 2 deletions CONFIGURATION.md
Original file line number Diff line number Diff line change
Expand Up @@ -54,15 +54,15 @@ heartbeat_interval_ms | * | 1 .. 3600000 | 1000
coordinator_query_interval_ms | * | 1 .. 3600000 | 600000 | How often to query for the current client group coordinator. If the currently assigned coordinator is down the configured query interval will be divided by ten to more quickly recover in case of coordinator reassignment
auto_commit_interval_ms | C | 0 .. 86400000 | 5000 | The frequency in milliseconds that the consumer offsets are committed (written) to offset storage. (0 = disable). This setting is used by the high-level consumer
queued_min_messages | C | 1 .. 10000000 | 100000 | Minimum number of messages per topic+partition in the local consumer queue
queued_max_messages_kbytes | C | 1 .. 1000000000 | 1000000 | Maximum number of kilobytes per topic+partition in the local consumer queue. This value may be overshot by `fetch_message_max_bytes`
queued_max_messages_kbytes | C | 1 .. 1000000000 | 1048576 | Maximum number of kilobytes per topic+partition in the local consumer queue. This value may be overshot by `fetch_message_max_bytes`
fetch_wait_max_ms | C | 0 .. 300000 | 100 | Maximum time the broker may wait to fill the response with `fetch_min_bytes`
fetch_message_max_bytes | C | 1 .. 1000000000 | 1048576 | Initial maximum number of bytes per topic+partition to request when fetching messages from the broker. If the client encounters a message larger than this value it will gradually try to increase it until the entire message can be fetched
fetch_min_bytes | C | 1 .. 100000000 | 1 | Minimum number of bytes the broker responds with. If fetch.wait.max.ms expires the accumulated data will be sent to the client regardless of this setting
fetch_error_backoff_ms | C | 0 .. 300000 | 500 | How long to postpone the next fetch request for a topic+partition in case of a fetch error
offset_store_method | C | none, file, broker | broker | Offset commit store method: 'file' - local file store (offset.store.path, et.al), 'broker' - broker commit store (requires Apache Kafka 0.8.2 or later on the broker)
check_crcs | C | true, false | false | Verify CRC32 of consumed messages, ensuring no on-the-wire or on-disk corruption to the messages occurred. This check comes at slightly increased CPU usage
queue_buffering_max_messages | P | 1 .. 10000000 | 100000 | Maximum number of messages allowed on the producer queue
queue_buffering_max_kbytes | P | 1 .. 2097151 | 4000000 | Maximum number of kilobytes per topic+partition in the local consumer queue. This value may be overshot by fetch_message_max_bytes. This property has higher priority than queued_min_messages.
queue_buffering_max_kbytes | P | 1 .. 2097151 | 1048576 | Maximum number of kilobytes per topic+partition in the local consumer queue. This value may be overshot by fetch_message_max_bytes. This property has higher priority than queued_min_messages.
queue_buffering_max_ms | P | 0 .. 900000 | 0 | Maximum time, in milliseconds, for buffering data on the producer queue
queue_buffering_overflow_strategy | P | local_disk_queue, block_calling_process, drop_records | local_disk_queue| What strategy to pick in case the memory queue is full: write messages on a local disk queue and send them in kafka when the in memory queue have enough space, block calling process until memory queue has enough space or drop the messages
message_send_max_retries | P | 0 .. 10000000 | 2 | How many times to retry sending a failing MessageSet. **Note:** retrying may cause reordering
Expand Down
2 changes: 1 addition & 1 deletion build_deps.sh
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@ fi

REPO=https://github.com/edenhill/librdkafka.git
BRANCH=master
REV=261371dc0edef4cea9e58a076c8e8aa7dc50d452
REV=b581d0d9df282847f76e8b9e87337161959d39c9

function fail_check
{
Expand Down

0 comments on commit 2f8c1dc

Please sign in to comment.