File tree Expand file tree Collapse file tree 1 file changed +0
-9
lines changed Expand file tree Collapse file tree 1 file changed +0
-9
lines changed Original file line number Diff line number Diff line change 11#include < stdexcept>
22#include < iostream>
3- #include < csignal>
43#include < boost/program_options.hpp>
54#include " cppkafka/producer.h"
65#include " cppkafka/configuration.h"
@@ -22,11 +21,8 @@ using cppkafka::BrokerMetadata;
2221
2322namespace po = boost::program_options;
2423
25- bool running = true ;
26-
2724int main (int argc, char * argv[]) {
2825 string brokers;
29- string group_id;
3026
3127 po::options_description options (" Options" );
3228 options.add_options ()
@@ -48,14 +44,9 @@ int main(int argc, char* argv[]) {
4844 return 1 ;
4945 }
5046
51- // Stop processing on SIGINT
52- signal (SIGINT, [](int ) { running = false ; });
53-
5447 // Construct the configuration
5548 Configuration config = {
5649 { " metadata.broker.list" , brokers },
57- // Disable auto commit
58- { " enable.auto.commit" , false }
5950 };
6051
6152 try {
You can’t perform that action at this time.
0 commit comments