File tree Expand file tree Collapse file tree 2 files changed +2
-2
lines changed Expand file tree Collapse file tree 2 files changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -4,7 +4,7 @@ v1.4.0 is a feature release. It is supported for all usage.
4
4
5
5
## Enhancements
6
6
7
- 1 . Adds support for ` highWatermark ` , ` offsetLag() ` , and ` offsetLagLow() ` in ` eachBatch ` callback (#).
7
+ 1 . Adds support for ` highWatermark ` , ` offsetLag() ` , and ` offsetLagLow() ` in ` eachBatch ` callback (#317 ).
8
8
9
9
10
10
# confluent-kafka-javascript v1.3.0
Original file line number Diff line number Diff line change @@ -871,7 +871,7 @@ class Consumer {
871
871
if ( Number . isInteger ( watermarkOffsets . highOffset ) ) {
872
872
highWatermark = watermarkOffsets . highOffset . toString ( ) ;
873
873
/* While calculating lag, we subtract 1 from the high offset
874
- * for compability reasons with KafkaJS's API */
874
+ * for compatibility reasons with KafkaJS's API */
875
875
offsetLag_ = ( watermarkOffsets . highOffset - 1 ) - messages [ messages . length - 1 ] . offset ;
876
876
offsetLagLow_ = ( watermarkOffsets . highOffset - 1 ) - messages [ 0 ] . offset ;
877
877
}
You can’t perform that action at this time.
0 commit comments