Skip to content

Commit 5f9cd9f

Browse files
Fix KafkaJS
1 parent d38f5e1 commit 5f9cd9f

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

proxy/protocol/responses.go

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -399,7 +399,8 @@ func modifyApiVersionsResponse(decodedStruct *Struct, fn config.NetAddressMappin
399399

400400
schema := versions[0].(*Struct).GetSchema()
401401

402-
values := []any{int16(17), int16(0), int16(1)}
402+
// v1 Sasl auth does not seem to work with KafkaJS so pin to v0
403+
values := []any{int16(17), int16(0), int16(0)}
403404

404405
// version 3+ of the api versions response
405406
if len(schema.GetFields()) > 3 {

0 commit comments

Comments
 (0)