Skip to content

Commit ad22c27

Browse files
committed
Update README with transactional producer
1 parent 093d341 commit ad22c27

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

README.md

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -262,6 +262,11 @@ To see the configuration options available to you, see the [Configuration](#conf
262262
|`producer.setPollInterval(interval)` | Polls the producer on this interval, handling disconnections and reconnection. Set it to 0 to turn it off. |
263263
|`producer.produce(topic, partition, msg, key, timestamp, opaque)`| Sends a message. <br><br>The `produce()` method throws when produce would return an error. Ordinarily, this is just if the queue is full. |
264264
|`producer.flush(timeout, callback)`| Flush the librdkafka internal queue, sending all messages. Default timeout is 500ms |
265+
|`producer.initTransactions(timeout, callback)`| Initializes the transactional producer. |
266+
|`producer.beginTransaction(callback)`| Starts a new transaction. |
267+
|`producer.sendOffsetsToTransaction(offsets, consumer, timeout, callback)`| Sends consumed topic-partition-offsets to the broker, which will get committed along with the transaction. |
268+
|`producer.abortTransaction(timeout, callback)`| Aborts the ongoing transaction. |
269+
|`producer.commitTransaction(timeout, callback)`| Commits the ongoing transaction. |
265270

266271
##### Events
267272

0 commit comments

Comments
 (0)