You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
- The `heartbeat()` no longer needs to be called by the user in the `eachMessage/eachBatch` callback. Heartbeats are automatically managed by librdkafka.
302
-
- The `partitionsConsumedConcurrently` property is not supported at the moment.
303
-
- An API compatible version of `eachBatch` is available, but the batch size never exceeds 1.
304
-
The property `eachBatchAutoResolve` is supported. Within the `eachBatch` callback, use of `uncommittedOffsets` is unsupported,
305
-
and within the returned batch, `offsetLag` and `offsetLagLow` are unsupported, and `commitOffsetsIfNecessary` is a no-op.
301
+
- The `heartbeat()` no longer needs to be called by the user in the `eachMessage/eachBatch` callback.
302
+
Heartbeats are automatically managed by librdkafka.
303
+
- The `partitionsConsumedConcurrently` is supported by both `eachMessage` and `eachBatch`.
304
+
- An API compatible version of `eachBatch` is available, but the batch size calculation is not
305
+
as per configured parameters, rather, a constant maximum size is configured internally. This is subject
306
+
to change.
307
+
The property `eachBatchAutoResolve` is supported.
308
+
Within the `eachBatch` callback, use of `uncommittedOffsets` is unsupported,
309
+
and within the returned batch, `offsetLag` and `offsetLagLow` are unsupported.
306
310
* `commitOffsets`:
307
311
- Does not yet support sending metadata for topic partitions being committed.
308
312
- If called with no arguments, it commits all offsets passed to the user (or the stored offsets, if manually handling offset storage using `consumer.storeOffsets`).
0 commit comments