gerrit.onap Code Review - dcaegen2/collectors/hv-ves.git/commit

Code Review / dcaegen2 / collectors / hv-ves.git / commit

author	kjaniak <kornel.janiak@nokia.com>
	Wed, 19 Jun 2019 06:39:33 +0000 (08:39 +0200)
committer	kjaniak <kornel.janiak@nokia.com>
	Tue, 25 Jun 2019 13:52:13 +0000 (15:52 +0200)
commit	7808010c1a18531ee9b618f934d31816193cac38
tree	3680678be6f909054ff3a022aeda35b1ee5e47ac	tree \| snapshot
parent	e52b0ef6c1c3b502f840f08a17b6594e17957db1	commit \| diff

Implement message counting in consumer

Issue-ID: DCAEGEN2-1635
Change-Id: I2666de7bad27052d9cefa0f687ad0772d4c9a95d
Signed-off-by: kjaniak <kornel.janiak@nokia.com>

20 files changed:

build/hv-collector-coverage/pom.xml		diff \| blob \| history
sources/hv-collector-dcae-app-simulator/pom.xml		diff \| blob \| history
sources/hv-collector-dcae-app-simulator/src/main/kotlin/org/onap/dcae/collectors/veshv/simulators/dcaeapp/impl/DcaeAppSimulator.kt		diff \| blob \| history
sources/hv-collector-dcae-app-simulator/src/main/kotlin/org/onap/dcae/collectors/veshv/simulators/dcaeapp/impl/adapters/DcaeAppApiServer.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
sources/hv-collector-dcae-app-simulator/src/main/kotlin/org/onap/dcae/collectors/veshv/simulators/dcaeapp/main.kt		diff \| blob \| history
sources/hv-collector-dcae-app-simulator/src/test/kotlin/org/onap/dcae/collectors/veshv/simulators/dcaeapp/impl/DcaeAppSimulatorTest.kt		diff \| blob \| history
sources/hv-collector-kafka-consumer/pom.xml		diff \| blob \| history
sources/hv-collector-kafka-consumer/src/main/kotlin/org/onap/dcae/collectors/veshv/kafkaconsumer/metrics/Metrics.kt		diff \| blob \| history
sources/hv-collector-kafka-consumer/src/main/kotlin/org/onap/dcae/collectors/veshv/kafkaconsumer/metrics/MicrometerMetrics.kt		diff \| blob \| history
sources/hv-collector-kafka-consumer/src/main/kotlin/org/onap/dcae/collectors/veshv/kafkaconsumer/state/OffsetConsumer.kt	[new file with mode: 0644]	blob
sources/hv-collector-kafka-consumer/src/main/resources/logback.xml	[new file with mode: 0644]	blob
sources/hv-collector-kafka-consumer/src/test/kotlin/org/onap/dcae/collectors/veshv/kafkaconsumer/state/OffsetConsumerTest.kt	[new file with mode: 0644]	blob
sources/hv-collector-kafka/pom.xml	[new file with mode: 0644]	blob
sources/hv-collector-kafka/src/main/kotlin/org/onap/dcae/collectors/veshv/kafka/api/ConsumerFactory.kt	[new file with mode: 0644]	blob
sources/hv-collector-kafka/src/main/kotlin/org/onap/dcae/collectors/veshv/kafka/api/KafkaConsumer.kt	[new file with mode: 0644]	blob
sources/hv-collector-kafka/src/main/kotlin/org/onap/dcae/collectors/veshv/kafka/impl/KafkaSource.kt	[moved from sources/hv-collector-dcae-app-simulator/src/main/kotlin/org/onap/dcae/collectors/veshv/simulators/dcaeapp/impl/adapters/KafkaSource.kt with 97% similarity]	diff \| blob \| history
sources/hv-collector-kafka/src/test/kotlin/org/onap/dcae/collectors/veshv/kafka/api/ConsumerFactoryTest.kt	[new file with mode: 0644]	blob
sources/hv-collector-kafka/src/test/kotlin/org/onap/dcae/collectors/veshv/kafka/impl/KafkaSourceTest.kt	[moved from sources/hv-collector-dcae-app-simulator/src/test/kotlin/org/onap/dcae/collectors/veshv/simulators/dcaeapp/impl/adapters/KafkaSourceTest.kt with 95% similarity]	diff \| blob \| history
sources/pom.xml		diff \| blob \| history

High Volume VES Collector

RSS Atom