Skip to content

Commit 6b2a155

Browse files
mhowlettedenhill
authored andcommitted
Changed isolation.level default to read_committed
1 parent 7632802 commit 6b2a155

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

CONFIGURATION.md

+1-1
Original file line numberDiff line numberDiff line change
@@ -106,7 +106,7 @@ fetch.max.bytes | C | 0 .. 2147483135 | 52428800
106106
fetch.min.bytes | C | 1 .. 100000000 | 1 | low | 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. <br>*Type: integer*
107107
fetch.error.backoff.ms | C | 0 .. 300000 | 500 | medium | How long to postpone the next fetch request for a topic+partition in case of a fetch error. <br>*Type: integer*
108108
offset.store.method | C | none, file, broker | broker | low | **DEPRECATED** Offset commit store method: 'file' - DEPRECATED: local file store (offset.store.path, et.al), 'broker' - broker commit store (requires Apache Kafka 0.8.2 or later on the broker). <br>*Type: enum value*
109-
isolation.level | C | read_uncommitted, read_committed | read_uncommitted | high | Controls how to read messages written transactionally: `read_committed` - only return transactional messages which have been committed. `read_uncommitted` - return all messages, even transactional messages which have been aborted. <br>*Type: enum value*
109+
isolation.level | C | read_uncommitted, read_committed | read_committed | high | Controls how to read messages written transactionally: `read_committed` - only return transactional messages which have been committed. `read_uncommitted` - return all messages, even transactional messages which have been aborted. <br>*Type: enum value*
110110
consume_cb | C | | | low | Message consume callback (set with rd_kafka_conf_set_consume_cb()) <br>*Type: pointer*
111111
rebalance_cb | C | | | low | Called after consumer group has been rebalanced (set with rd_kafka_conf_set_rebalance_cb()) <br>*Type: pointer*
112112
offset_commit_cb | C | | | low | Offset commit result propagation callback. (set with rd_kafka_conf_set_offset_commit_cb()) <br>*Type: pointer*

src/rdkafka_conf.c

+1-1
Original file line numberDiff line numberDiff line change
@@ -994,7 +994,7 @@ static const struct rd_kafka_property rd_kafka_properties[] = {
994994
"`read_committed` - only return transactional messages which have "
995995
"been committed. `read_uncommitted` - return all messages, even "
996996
"transactional messages which have been aborted.",
997-
.vdef = RD_KAFKA_READ_UNCOMMITTED,
997+
.vdef = RD_KAFKA_READ_COMMITTED,
998998
.s2i = {
999999
{ RD_KAFKA_READ_UNCOMMITTED, "read_uncommitted" },
10001000
{ RD_KAFKA_READ_COMMITTED, "read_committed" }

0 commit comments

Comments
 (0)