Enable Kafka consumer offset committing 38/87438/1
authorFilip Krzywka <filip.krzywka@nokia.com>
Fri, 10 May 2019 09:53:21 +0000 (11:53 +0200)
committerFilip Krzywka <filip.krzywka@nokia.com>
Fri, 10 May 2019 09:53:51 +0000 (11:53 +0200)
commitdc936d27d761bde31ac5916a84efa2f48ec32b83
tree0c52440545105d137d13c238cb54a2e0c364d167
parente3b124ab11ac8c837ff692539696d1e43fcd8247
Enable Kafka consumer offset committing

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

By acknowledging manually, we will mark every message for committing,
which will be performed according to ConsumerConfiguration.
This way, Kafka broker should persist consumer offset.

Change-Id: I0c5156ff8df9bb3341e733e50a3c6866fdd94976
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