Puts consumers into read_committed mode
This commit is contained in:
@@ -15,6 +15,7 @@ spring:
|
|||||||
valueDeserializer: net.mguenther.gtd.kafka.serialization.ItemEventDeserializer
|
valueDeserializer: net.mguenther.gtd.kafka.serialization.ItemEventDeserializer
|
||||||
autoOffsetReset: earliest
|
autoOffsetReset: earliest
|
||||||
enableAutoCommit: false
|
enableAutoCommit: false
|
||||||
|
isolationLevel: read_committed
|
||||||
listener:
|
listener:
|
||||||
ackMode: MANUAL
|
ackMode: MANUAL
|
||||||
|
|
||||||
|
|||||||
@@ -11,6 +11,7 @@ spring:
|
|||||||
valueDeserializer: net.mguenther.gtd.kafka.serialization.ItemEventDeserializer
|
valueDeserializer: net.mguenther.gtd.kafka.serialization.ItemEventDeserializer
|
||||||
autoOffsetReset: latest
|
autoOffsetReset: latest
|
||||||
enableAutoCommit: false
|
enableAutoCommit: false
|
||||||
|
isolationLevel: read_committed
|
||||||
listener:
|
listener:
|
||||||
ackMode: MANUAL
|
ackMode: MANUAL
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user