Skip to content

Commit 02cc362

Browse files
committed
test(kafka): add tests to handle delimited protobufs
1 parent ef9bb52 commit 02cc362

File tree

4 files changed

+91
-375
lines changed

4 files changed

+91
-375
lines changed

packages/kafka/src/types/types.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -211,7 +211,7 @@ interface MSKEvent {
211211
};
212212
}
213213

214-
interface ProtobufMessage<T> {
214+
interface ProtobufMessage<T = unknown> {
215215
decode(reader: Reader | Uint8Array, length?: number): T;
216216
}
217217

packages/kafka/tests/protos/product.cjs.generated.d.ts

Lines changed: 0 additions & 110 deletions
This file was deleted.

packages/kafka/tests/protos/product.cjs.generated.js

Lines changed: 0 additions & 264 deletions
This file was deleted.

0 commit comments

Comments
 (0)