import java.time.Duration;
import java.util.Arrays;
-import java.util.concurrent.ExecutorService;
@Slf4j
@RequiredArgsConstructor
public class SimpleConsumer implements Runnable
{
- private final ExecutorService executor;
private final String id;
private final String topic;
private final Consumer<String, String> consumer;