Skip to content
Snippets Groups Projects
Commit 084806a5 authored by Sergey Yakubov's avatar Sergey Yakubov
Browse files

fix secret key - removed spaces

parent fdb503dc
No related branches found
No related tags found
No related merge requests found
......@@ -150,7 +150,7 @@ std::vector<std::thread> StartConsumerThreads(const Args& args, const ProducerPt
auto err = ProcessNextEvent(args, broker, producer);
if (err) {
(*errors)[i] += ProcessError(err);
if (err == asapo::ConsumerErrorTemplates::kEndOfStream) {
if (err == asapo::ConsumerErrorTemplates::kEndOfStream || err == asapo::ConsumerErrorTemplates::kWrongInput) {
break;
}
}
......
12ljzgneasfd
12ljzgneasfd
\ No newline at end of file
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment