Closed ghost closed 5 years ago
After upgrade of Kafka-clients to version 2.1.1, the operator uses a deprecated Java API:
close(long, TimeUnit)
KafkaConsumer
poll(long)
After upgrade of Kafka-clients to version 2.1.1, the operator uses a deprecated Java API:
close(long, TimeUnit)
from the typeKafkaConsumer
is deprecatedpoll(long)
from the typeKafkaConsumer
is deprecated