Comparing version
{ | ||
"name": "kafkajs", | ||
"version": "1.13.0-beta.31", | ||
"version": "1.13.0-beta.32", | ||
"description": "A modern Apache Kafka client for node.js", | ||
@@ -82,5 +82,5 @@ "author": "Tulio Ornelas <ornelas.tulio@gmail.com>", | ||
"kafkajs": { | ||
"sha": "3c27a1822254e8669904fc19c161faa2ced67c72", | ||
"compare": "https://github.com/tulios/kafkajs/compare/v1.12.0...3c27a1822254e8669904fc19c161faa2ced67c72" | ||
"sha": "01007496fa54c0cc8a00c48d91da569e2fae2e51", | ||
"compare": "https://github.com/tulios/kafkajs/compare/v1.12.0...01007496fa54c0cc8a00c48d91da569e2fae2e51" | ||
} | ||
} |
@@ -525,3 +525,3 @@ /// <reference types="node" /> | ||
export type TopicPartitions = { topic: string; partitions: number[] } | ||
export type TopicPartitionOffsetAndMedata = { | ||
export type TopicPartitionOffsetAndMetadata = { | ||
topic: string | ||
@@ -533,2 +533,5 @@ partition: number | ||
// TODO: Remove with 2.x | ||
export type TopicPartitionOffsetAndMedata = TopicPartitionOffsetAndMetadata | ||
export type Batch = { | ||
@@ -674,3 +677,3 @@ topic: string | ||
run(config?: ConsumerRunConfig): Promise<void> | ||
commitOffsets(topicPartitions: Array<TopicPartitionOffsetAndMedata>): Promise<void> | ||
commitOffsets(topicPartitions: Array<TopicPartitionOffsetAndMetadata>): Promise<void> | ||
seek(topicPartition: { topic: string; partition: number; offset: string }): void | ||
@@ -677,0 +680,0 @@ describeGroup(): Promise<GroupDescription> |
516246
0.02%15290
0.01%