We are seeing data loss, whenever we see "NotLeaderForPartitionException" exception, We are using 0.8.2 java client publisher API with callback, when i get callback with the error i am logging them in a file and retrying them later. So number of errors = number of logged events are matching but overal,l few events are missing. Observations Timestamp of missing events looks like just before the timestamp of the error occurrence, meaning every time when we get this error we are loosing couple events which are sent just before the error time.
Is there any way to handle this, should it be handle at client side or some tuning required at kafka side. t SunilKalva
