import java.time.Duration;
import java.util.Arrays;
-import java.util.concurrent.ExecutorService;
@Slf4j
@RequiredArgsConstructor
-public class SimpleConsumer implements Runnable
+public class SimpleConsumer
{
- private final ExecutorService executor;
private final String id;
private final String topic;
private final Consumer<String, String> consumer;
private long consumed = 0;
- @Override
public void run()
{
try