Changed isolation.level default to read_committed

millin · Aug 28, 2019 · 6b2a155 · 6b2a155
1 parent 7632802
commit 6b2a155
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/CONFIGURATION.md b/CONFIGURATION.md
@@ -106,7 +106,7 @@ fetch.max.bytes                          |  C  | 0 .. 2147483135 |      52428800
 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*
 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*
 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*
-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*
+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*
 consume_cb                               |  C  |                 |               | low        | Message consume callback (set with rd_kafka_conf_set_consume_cb()) <br>*Type: pointer*
 rebalance_cb                             |  C  |                 |               | low        | Called after consumer group has been rebalanced (set with rd_kafka_conf_set_rebalance_cb()) <br>*Type: pointer*
 offset_commit_cb                         |  C  |                 |               | low        | Offset commit result propagation callback. (set with rd_kafka_conf_set_offset_commit_cb()) <br>*Type: pointer*

diff --git a/src/rdkafka_conf.c b/src/rdkafka_conf.c
@@ -994,7 +994,7 @@ static const struct rd_kafka_property rd_kafka_properties[] = {
           "`read_committed` - only return transactional messages which have "
           "been committed. `read_uncommitted` - return all messages, even "
           "transactional messages which have been aborted.",
-          .vdef = RD_KAFKA_READ_UNCOMMITTED,
+          .vdef = RD_KAFKA_READ_COMMITTED,
           .s2i = {
                         { RD_KAFKA_READ_UNCOMMITTED, "read_uncommitted" },
                         { RD_KAFKA_READ_COMMITTED, "read_committed" }