HOTFIX: GlobalStateManagerImpl in trunk has renamed the consumer field
@@ -192,7 +192,7 @@ public class GlobalStateManagerImpl implements GlobalStateManager {
if (record.key() != null) {
restoreRecords.add(KeyValue.pair(record.key(), record.value()));
}
- offset = consumer.position(topicPartition);
+ offset = globalConsumer.position(topicPartition);
}
stateRestoreAdapter.restoreAll(restoreRecords);
stateRestoreListener.onBatchRestored(topicPartition, storeName, offset, restoreRecords.size());
