class TracingConsumer implements Consumer<K, V> {

  public ConsumerRecords<K, V> poll(Duration timeout) {
    return poll(timeout.toMillis());
  }

    TracingConsumer(Consumer<K, V> delegate, KafkaTracing kafkaTracing);

}