Change-Id: I92f2947f352601c851309b8aa5bd8d6663246143
my $max_partitions = 3; # specify max partitions, which is more than or equal to workers
my %packages_level = (); # save the level of packages, which are calculated by get_top_order() algorithm
my $connection;
-my $connection1;
my $producer;
my $consumer;
GetOptions (
$producer = Kafka::Producer->new( Connection => $connection );
$consumer = Kafka::Consumer->new( Connection => $connection );
} catch {
- dealWithException($_);
+ dealWithException($_);
};
my $cur_level = 0;