Skip to content

Commit 11f840e

Browse files
authored
Fix typo in producer eos (#172)
* Fix typo in producer eos * CHANGELOG updates
1 parent 5225278 commit 11f840e

File tree

2 files changed

+13
-1
lines changed

2 files changed

+13
-1
lines changed

CHANGELOG.md

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,20 @@
1+
# confluent-kafka-javascript v0.5.1
2+
3+
v0.5.1 is a limited availability maintenance release. It is supported for all usage.
4+
5+
## Fixes
6+
7+
1. Fix an issue where `sendOffsets` wasn't working correctly in the transactional
8+
producer (#172).
9+
110

211
# confluent-kafka-javascript v0.5.0
312

413
v0.5.0 is a limited availability feature release. It is supported for all usage.
514

15+
Note: v0.5.0 was not released because of the bug mentioned in v0.5.1 section. Instead,
16+
v0.5.1 was released with the fix directly.
17+
618
## Enhancements
719

820
1. Add support for an Admin API to delete records.(#141).

lib/kafkajs/_producer.js

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -513,7 +513,7 @@ class Producer {
513513
return new Promise((resolve, reject) => {
514514
this.#internalClient.sendOffsetsToTransaction(
515515
this.#flattenTopicPartitionOffsets(topics).map(topicPartitionOffsetToRdKafka),
516-
consumer._getInternalConsumer(),
516+
consumer._getInternalClient(),
517517
async err => {
518518
if (err)
519519
reject(createKafkaJsErrorFromLibRdKafkaError(err));

0 commit comments

Comments
 (0)