When I use KafkaSource, the following error is raised:
07 Dec 2015 04:13:11,571 ERROR [ConsumerFetcherThread-]
(kafka.utils.Logging$class.error:97) - Current offset 482243452 for partition
[5] out of range; reset offset to 483146676
Current offset 482243452 for partition [log,5] out of range; reset
offset to 483146676
consumed offset: 482243452 doesn't match fetch offset: 483146676 for
log:5: fetched offset = 483147611: consumed offset = 482243452;
Consumer may lose data
But the default configuration of KafkaSource is used.
What happens during the agent running?
Thanks