You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
While producer.cpp compiled successfully, when compiling rdkafka_complex_consumer_example.cpp,
#include <librdkafka/rdkafkacpp.h> header included, shows the following errors: g++ rdkafka_complex_consumer_example.cpp -lrdkafka++ rdkafka_complex_consumer_example.cpp: In member function ‘virtual void ExampleRebalanceCb::rebalance_cb(RdKafka::KafkaConsumer*, RdKafka::ErrorCode, std::vector<RdKafka::TopicPartition*>&)’: rdkafka_complex_consumer_example.cpp:154:14: error: ‘Error’ is not a member of ‘RdKafka’ 154 | RdKafka::Error *error = NULL; | ^~~~~ rdkafka_complex_consumer_example.cpp:154:21: error: ‘error’ was not declared in this scope; did you mean ‘perror’? 154 | RdKafka::Error *error = NULL; | ^~~~~ | perror rdkafka_complex_consumer_example.cpp:158:21: error: ‘class RdKafka::KafkaConsumer’ has no member named ‘rebalance_protocol’ 158 | if (consumer->rebalance_protocol() == "COOPERATIVE") | ^~~~~~~~~~~~~~~~~~ rdkafka_complex_consumer_example.cpp:159:27: error: ‘class RdKafka::KafkaConsumer’ has no member named ‘incremental_assign’ 159 | error = consumer->incremental_assign(partitions); | ^~~~~~~~~~~~~~~~~~ rdkafka_complex_consumer_example.cpp:164:21: error: ‘class RdKafka::KafkaConsumer’ has no member named ‘rebalance_protocol’ 164 | if (consumer->rebalance_protocol() == "COOPERATIVE") { | ^~~~~~~~~~~~~~~~~~ rdkafka_complex_consumer_example.cpp:165:27: error: ‘class RdKafka::KafkaConsumer’ has no member named ‘incremental_unassign’ 165 | error = consumer->incremental_unassign(partitions); | ^~~~~~~~~~~~~~~~~~~~ rdkafka_complex_consumer_example.cpp:176:14: error: type ‘<type error>’ argument given to ‘delete’, expected pointer 176 | delete error; | ^~~~~
reacted with thumbs up emoji reacted with thumbs down emoji reacted with laugh emoji reacted with hooray emoji reacted with confused emoji reacted with heart emoji reacted with rocket emoji reacted with eyes emoji
Uh oh!
There was an error while loading. Please reload this page.
Uh oh!
There was an error while loading. Please reload this page.
-
While producer.cpp compiled successfully, when compiling rdkafka_complex_consumer_example.cpp,
#include <librdkafka/rdkafkacpp.h> header included, shows the following errors:
g++ rdkafka_complex_consumer_example.cpp -lrdkafka++ rdkafka_complex_consumer_example.cpp: In member function ‘virtual void ExampleRebalanceCb::rebalance_cb(RdKafka::KafkaConsumer*, RdKafka::ErrorCode, std::vector<RdKafka::TopicPartition*>&)’: rdkafka_complex_consumer_example.cpp:154:14: error: ‘Error’ is not a member of ‘RdKafka’ 154 | RdKafka::Error *error = NULL; | ^~~~~ rdkafka_complex_consumer_example.cpp:154:21: error: ‘error’ was not declared in this scope; did you mean ‘perror’? 154 | RdKafka::Error *error = NULL; | ^~~~~ | perror rdkafka_complex_consumer_example.cpp:158:21: error: ‘class RdKafka::KafkaConsumer’ has no member named ‘rebalance_protocol’ 158 | if (consumer->rebalance_protocol() == "COOPERATIVE") | ^~~~~~~~~~~~~~~~~~ rdkafka_complex_consumer_example.cpp:159:27: error: ‘class RdKafka::KafkaConsumer’ has no member named ‘incremental_assign’ 159 | error = consumer->incremental_assign(partitions); | ^~~~~~~~~~~~~~~~~~ rdkafka_complex_consumer_example.cpp:164:21: error: ‘class RdKafka::KafkaConsumer’ has no member named ‘rebalance_protocol’ 164 | if (consumer->rebalance_protocol() == "COOPERATIVE") { | ^~~~~~~~~~~~~~~~~~ rdkafka_complex_consumer_example.cpp:165:27: error: ‘class RdKafka::KafkaConsumer’ has no member named ‘incremental_unassign’ 165 | error = consumer->incremental_unassign(partitions); | ^~~~~~~~~~~~~~~~~~~~ rdkafka_complex_consumer_example.cpp:176:14: error: type ‘<type error>’ argument given to ‘delete’, expected pointer 176 | delete error; | ^~~~~
Beta Was this translation helpful? Give feedback.
All reactions