Code Review / dcaegen2 / collectors / hv-ves.git / commit
? search:
summary | shortlog | log | commit | commitdiff | review | tree
(parent: 66254ca) | patch
Make offset consumer more generic 48/106748/3
authorJoanna Jeremicz <joanna.jeremicz@nokia.com>
Tue, 28 Apr 2020 11:25:46 +0000 (13:25 +0200)
committerJoanna Jeremicz <joanna.jeremicz@nokia.com>
Thu, 30 Apr 2020 11:16:40 +0000 (13:16 +0200)
commitf3b6f88fe48da4808f2521cb0769cc77caf4f3fb
tree45e741e4cf4de5a6d6c5eff01a8d98c667516805tree | snapshot
parent66254ca1c5df0d7971764799088c8f20c79f4ca7commit | diff
Make offset consumer more generic

Offsets are now correctly read despite of partitions number on topic.

Issue-ID: DCAEGEN2-1576
Change-Id: Id89bebbcf1b6181a2f9fd5a4a4600329d046c5e5
Signed-off-by: Joanna Jeremicz <joanna.jeremicz@nokia.com>
sources/hv-collector-commandline/src/main/kotlin/org/onap/dcae/collectors/veshv/commandline/CommandLineOption.kt diff | blob | history
sources/hv-collector-kafka-consumer/src/main/kotlin/org/onap/dcae/collectors/veshv/kafkaconsumer/impl/OffsetKafkaConsumer.kt diff | blob | history
sources/hv-collector-kafka-consumer/src/test/kotlin/org/onap/dcae/collectors/veshv/kafkaconsumer/config/ArgKafkaConsumerConfigurationTest.kt diff | blob | history
sources/hv-collector-kafka-consumer/src/test/kotlin/org/onap/dcae/collectors/veshv/kafkaconsumer/impl/OffsetKafkaConsumerTest.kt diff | blob | history
High Volume VES Collector