- this.offsets = new long[numShards];
- this.handlers = new MessageHandler[numShards];
- for (int i=0; i< numShards; i++)
- {
- this.offsets[i] = 0l;
- this.handlers[i] = new MessageHandler(consumer, new TopicPartition(topic, i));
- }
+ // this.offsets = new long[numShards];
+ // for (int i=0; i< numShards; i++)
+ // {
+ // this.offsets[i] = 0l;
+ // }