aboutsummaryrefslogtreecommitdiffstats
path: root/sources/hv-collector-kafka-consumer
AgeCommit message (Collapse)AuthorFilesLines
2019-07-12Use consumers in mainIzabela Zawadzka4-9/+65
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
2019-07-08Merge "Measure message travel time"Piotr Jaszczyk7-152/+288
2019-07-05Increase coverage in new consumerFilip Krzywka1-0/+140
Change-Id: I58e88182e84a7d807d481e8cbd7196d8b82309ac Issue-ID: DCAEGEN2-1619 Signed-off-by: Filip Krzywka <filip.krzywka@nokia.com>
2019-07-05Merge "Add performance test producer deployment yaml"Piotr Jaszczyk1-111/+0
2019-07-05Add performance test producer deployment yamlJakub Dudycz1-111/+0
- create cloud performance test directory structure - move consumer deployment file to "tools/performence/cloud" directory Change-Id: Ia5c6d8ed15a2188ff9306cf788052f432dae1e33 Signed-off-by: Jakub Dudycz <jakub.dudycz@nokia.com> Issue-ID: DCAEGEN2-1652
2019-07-04Measure message travel timeIzabela Zawadzka7-152/+288
Issue-ID: DCAEGEN2-1654 Signed-off-by: Izabela Zawadzka <izabela.zawadzka@nokia.com> Change-Id: Ifd6597209c5be51d5b4ff5faf7b3b1b1a2871403
2019-07-04Merge "Change handling of offset metric for consumer app"Piotr Jaszczyk5-15/+26
2019-07-03Merge "Add K8S deployment for kafka-consumer"Piotr Jaszczyk1-0/+111
2019-07-03Change handling of offset metric for consumer appkjaniak5-15/+26
Change-Id: Ia83469783d64d0174624489df671006e72bc8948 Issue-ID: DCAEGEN2-1635 Signed-off-by: kjaniak <kornel.janiak@nokia.com>
2019-07-02Reorganize kafka modulekjaniak8-31/+248
Change-Id: I2eb7a8a6e92c9d89586b877f4cae438497b62ae2 Issue-ID: DCAEGEN2-1635 Signed-off-by: kjaniak <kornel.janiak@nokia.com>
2019-06-28Add K8S deployment for kafka-consumerFilip Krzywka1-0/+111
Change-Id: Idba5c738dc2062b30c32bb928d701614743f0828 Issue-ID: DCAEGEN2-1619 Signed-off-by: Filip Krzywka <filip.krzywka@nokia.com>
2019-06-27JJB alignment across DCAE components - DCAE HV-VESrajendrajaiswal1-1/+1
Change-Id: I815c32a91a3e710d9076495dbafcba420bde4da5 Issue-ID: DCAEGEN2-1578 Signed-off-by: rajendrajaiswal <rajendra.jaiswal@ericsson.com>
2019-06-26Implement kafka consumer metricsFilip Krzywka5-59/+116
- bump Micrometer version 1.0.8 -> 1.1.5 Change-Id: I7a00fbf252df0f31f12f8743e8719701bd282ce2 Issue-ID: DCAEGEN2-1626 Signed-off-by: Filip Krzywka <filip.krzywka@nokia.com>
2019-06-26Add environment configuration to kafka consumerFilip Krzywka2-4/+27
- HV-VES-specific environment prefix moved inside HvVes modules to allow simpler no-prefix API for other modules - created OptionDSL for brevity Change-Id: I2fabbda1280cc0f913f8a0a04b4a055f39ed1fae Issue-ID: DCAEGEN2-1626 Signed-off-by: Filip Krzywka <filip.krzywka@nokia.com>
2019-06-25Implement message counting in consumerkjaniak6-8/+216
Issue-ID: DCAEGEN2-1635 Change-Id: I2666de7bad27052d9cefa0f687ad0772d4c9a95d Signed-off-by: kjaniak <kornel.janiak@nokia.com>
2019-06-19Expose Prometheus metrics in Kafka ConsumerJakub Dudycz7-3/+209
Change-Id: I9d0568a5fc296604d7ac7a45b8bbd0289b845938 Signed-off-by: Jakub Dudycz <jakub.dudycz@nokia.com> Issue-ID: DCAEGEN2-1626
2019-06-14Create Kafka Consumer project stubJakub Dudycz4-0/+165
Change-Id: Ib45ca6a9ab282dab509e34f9a3d3682373d794d3 Signed-off-by: Jakub Dudycz <jakub.dudycz@nokia.com> Issue-ID: DCAEGEN2-1619