public class Consumer<T> implements Managed {
private static final Logger logger = LoggerFactory.getLogger(Consumer.class);
private final KafkaConsumer<T> consumer;
private final ManagedPipeline<T> pipeline;
@Inject
<BUG>public Consumer(KafkaConsumer<T> kafkaConsumer, ManagedPipeline<T> pipeline) {
this.consumer = kafkaConsumer;</BUG>
this.pipeline = pipeline;
}
@Override

public class Consumer<T> implements Managed {
private static final Logger logger = LoggerFactory.getLogger(Consumer.class);
private final KafkaConsumer<T> consumer;
private final ManagedPipeline<T> pipeline;
@Inject
public Consumer(
@Assisted KafkaConsumer<T> kafkaConsumer,
@Assisted ManagedPipeline<T> pipeline) {
this.consumer = kafkaConsumer;
this.pipeline = pipeline;
}
@Override
