Code Review / dcaegen2 / collectors / hv-ves.git / commit
? search:
summary | shortlog | log | commit | commitdiff | review | tree
(parent: 6940c01) | patch
Enable Kafka consumer offset commiting 18/87418/2 dublin
authorFilip Krzywka <filip.krzywka@nokia.com>
Fri, 10 May 2019 06:08:08 +0000 (08:08 +0200)
committerFilip Krzywka <filip.krzywka@nokia.com>
Fri, 10 May 2019 06:35:12 +0000 (08:35 +0200)
commit73b06ecb7b7cf81cdb46549285bb0c0afbf182c5
treed6088f330306d8df01323d66dee7617a654195bbtree | snapshot
parent6940c01090bc30d7adc1203bb50bf8b2701670e2commit | diff
Enable Kafka consumer offset commiting

It appears that reactor-kafka is setting auto.commit property to false,
wich makes our CSITs fail nondeterministically due to automatic reset of
consumer offset.

By committing manually, Kafka broker should persist consumer offset.

Change-Id: Ie4af7ef516dcde450cc31a499d82c5a90a0ad6c1
Issue-ID: DCAEGEN2-1495
Signed-off-by: Filip Krzywka <filip.krzywka@nokia.com>
sources/hv-collector-dcae-app-simulator/src/main/kotlin/org/onap/dcae/collectors/veshv/simulators/dcaeapp/impl/adapters/KafkaSource.kt diff | blob | history
sources/hv-collector-dcae-app-simulator/src/main/kotlin/org/onap/dcae/collectors/veshv/simulators/dcaeapp/impl/consumer.kt diff | blob | history
High Volume VES Collector