Fix resetOffsets for manual partition assignment

This commit is contained in:
Gary Russell
2019-07-19 18:47:41 -04:00
parent 87399fe904
commit b2b1438ad7

View File

@@ -733,12 +733,17 @@ public class KafkaMessageChannelBinder extends
}
private Object checkReset(boolean resetOffsets, final Object resetTo) {
if (resetOffsets && !"earliest".equals(resetTo) && !"latest".equals(resetTo)) {
if (!resetOffsets) {
return null;
}
else if (!"earliest".equals(resetTo) && !"latest".equals(resetTo)) {
logger.warn("no (or unknown) " + ConsumerConfig.AUTO_OFFSET_RESET_CONFIG
+ " property cannot reset");
return null;
}
return resetTo;
else {
return resetTo;
}
}
@Override