We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 4938b92 commit 16650beCopy full SHA for 16650be
lib/BackbeatConsumer.js
@@ -823,6 +823,7 @@ class BackbeatConsumer extends EventEmitter {
823
});
824
// ensure consumer is active when calling offsetsStore() on
825
// it, to avoid raising an exception (invalid state)
826
+ // TODO : potential issue here, see BB-758
827
if (committableOffset !== null && !this.isPaused()) {
828
this._consumer.offsetsStore([{ topic, partition,
829
offset: committableOffset }]);
0 commit comments