mirror of
https://github.com/Telecominfraproject/wlan-cloud-lib-cppkafka.git
synced 2025-11-17 02:04:51 +00:00
@@ -65,7 +65,13 @@ Consumer::Consumer(Configuration config)
|
|||||||
}
|
}
|
||||||
|
|
||||||
Consumer::~Consumer() {
|
Consumer::~Consumer() {
|
||||||
close();
|
try {
|
||||||
|
close();
|
||||||
|
}
|
||||||
|
catch (const Exception&) {
|
||||||
|
// If close throws just silently ignore until there's some
|
||||||
|
// logging facility (if any)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
void Consumer::set_assignment_callback(AssignmentCallback callback) {
|
void Consumer::set_assignment_callback(AssignmentCallback callback) {
|
||||||
|
|||||||
Reference in New Issue
Block a user