mirror of
https://github.com/Telecominfraproject/wlan-cloud-lib-cppkafka.git
synced 2025-11-05 21:18:04 +00:00
Remove bogus code
This commit is contained in:
@@ -156,7 +156,7 @@ TEST_F(ConsumerTest, Rebalance) {
|
|||||||
consumer1.set_revocation_callback([&](const vector<TopicPartition>&) {
|
consumer1.set_revocation_callback([&](const vector<TopicPartition>&) {
|
||||||
revocation_called = true;
|
revocation_called = true;
|
||||||
});
|
});
|
||||||
consumer1.subscribe(KAFKA_TOPIC);
|
consumer1.subscribe({ KAFKA_TOPIC });
|
||||||
ConsumerRunner runner1(consumer1, 1, 3);
|
ConsumerRunner runner1(consumer1, 1, 3);
|
||||||
|
|
||||||
// Create a second consumer and subscribe to the topic
|
// Create a second consumer and subscribe to the topic
|
||||||
|
|||||||
Reference in New Issue
Block a user