Code Review / dcaegen2 / collectors / hv-ves.git / commit
? search:
summary | shortlog | log | commit | commitdiff | review | tree
(parent: dbf9712) | patch
Use consumers in main 33/91133/4
authorIzabela Zawadzka <izabela.zawadzka@nokia.com>
Wed, 10 Jul 2019 07:29:51 +0000 (09:29 +0200)
committerIzabela Zawadzka <izabela.zawadzka@nokia.com>
Fri, 12 Jul 2019 07:59:06 +0000 (09:59 +0200)
commita313a7fb4ba81e960397ec432ce02c28804a44b4
tree4178df42f3ee571b19872e851e5aaf5d17e270cbtree | snapshot
parentdbf9712c95867185931b6f15d12ded7b45437a24commit | diff
Use consumers in main

It includes --disable-processing flag.
Also fixed some issues with script for local performance test.
Also added KafkaConsumer::poll in OffsetKafka Consumer - without it KafkaConsumer::assignment returns empty set

Signed-off-by: Izabela Zawadzka <izabela.zawadzka@nokia.com>
Issue-ID: DCAEGEN2-1657
Change-Id: I95fadb45f321398346094dfa0c4a6e9da954c186
sources/hv-collector-kafka-consumer/src/main/kotlin/org/onap/dcae/collectors/veshv/kafkaconsumer/api/MetricsKafkaConsumer.kt [new file with mode: 0644] blob
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/main/kotlin/org/onap/dcae/collectors/veshv/kafkaconsumer/impl/ProcessingKafkaConsumer.kt diff | blob | history
sources/hv-collector-kafka-consumer/src/main/kotlin/org/onap/dcae/collectors/veshv/kafkaconsumer/main.kt diff | blob | history
tools/performance/local/docker-compose.yml diff | blob | history
tools/performance/local/local-performance-test.sh diff | blob | history
High Volume VES Collector