flume-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Zhishan Li <zhishan...@gmail.com>
Subject Kafka Source Error
Date Mon, 07 Dec 2015 04:37:47 GMT
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


Mime
View raw message