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

Reply via email to