When starting a KafkaConsumer, we need to call the position API to establish the next offset BEFORE reading the partition from raw redis.
This ensures that we will not miss any UVE changes that happen between the partition read and when we starting reading from kafka.
Moved mockkafka to broker version 0.9.0.1, to be compatible with the fallback kafka version used collector via librdkafka
set offsets.topic.replication.factor to 1 for kafka-broker to in mockkafka to prevent spurious errors in systemless test
Reviewed: https:/ /review. opencontrail. org/37395 github. com/Juniper/ contrail- controller/ commit/ 79feb17ec889609 c06c5e3bbcf0dad 5ca5a6199c
Committed: http://
Submitter: Zuul (<email address hidden>)
Branch: R4.1
commit 79feb17ec889609 c06c5e3bbcf0dad 5ca5a6199c
Author: Anish Mehta <email address hidden>
Date: Fri Nov 10 00:21:38 2017 -0800
When starting a KafkaConsumer, we need to call the position API to establish the next offset BEFORE reading the partition from raw redis.
This ensures that we will not miss any UVE changes that happen between the partition read and when we starting reading from kafka.
Moved mockkafka to broker version 0.9.0.1, to be compatible with the fallback kafka version used collector via librdkafka
set offsets. topic.replicati on.factor to 1 for kafka-broker to in mockkafka to prevent spurious errors in systemless test
Re-enabled the redis restart systemless test
Change-Id: I12c03648ab0ae6 b2571f86e46ed01 6117fcefa18
Closes-Bug: #1716799