Skip to content

Commit c1df16b

Browse files
ShogunPandaShogunPanda
authored
feat: Support Kafka 3.7.0 and 3.8.0. (#38)
* feat: Support Kafka 3.7.0 and 3.8.0. Signed-off-by: Paolo Insogna <[email protected]> * fixup Signed-off-by: Paolo Insogna <[email protected]> * fixup Signed-off-by: Paolo Insogna <[email protected]> * fixup Signed-off-by: Paolo Insogna <[email protected]> --------- Signed-off-by: Paolo Insogna <[email protected]>
1 parent 9b0b55c commit c1df16b

File tree

191 files changed

+5114
-337
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

191 files changed

+5114
-337
lines changed

‎.github/workflows/ci.yml

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -7,6 +7,7 @@ jobs:
77
matrix:
88
node-version: [22, 23]
99
os: [ubuntu-latest]
10+
kafka-version: ['3.7.0', '3.8.0', '3.9.0']
1011
runs-on: ${{matrix.os}}
1112
timeout-minutes: 10
1213
steps:
@@ -27,7 +28,11 @@ jobs:
2728
version: latest
2829
- name: Install dependencies
2930
run: pnpm install
30-
- name: Start Kafka Cluster
31+
- name: Start Kafka (${{ matrix.kafka-version }}) Cluster
3132
run: docker compose -f docker/compose-github-ci.yml up -d && pnpx wait-on tcp:9092 tcp:9093 tcp:9094
33+
env:
34+
KAFKA_VERSION: ${{ matrix.kafka-version }}
3235
- name: Run Tests
3336
run: pnpm run ci
37+
env:
38+
KAFKA_VERSION: ${{ matrix.kafka-version }}

‎docker/compose-github-ci.yml

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@
22
# _JAVA_OPTIONS: '-XX:UseSVE=0'
33
services:
44
controller-1:
5-
image: apache/kafka:3.9.0
5+
image: apache/kafka:${KAFKA_VERSION}
66
container_name: controller-1
77
environment:
88
KAFKA_NODE_ID: 1
@@ -14,7 +14,7 @@ services:
1414
KAFKA_GROUP_INITIAL_REBALANCE_DELAY_MS: 0
1515

1616
controller-2:
17-
image: apache/kafka:3.9.0
17+
image: apache/kafka:${KAFKA_VERSION}
1818
container_name: controller-2
1919
environment:
2020
KAFKA_NODE_ID: 2
@@ -26,7 +26,7 @@ services:
2626
KAFKA_GROUP_INITIAL_REBALANCE_DELAY_MS: 0
2727

2828
controller-3:
29-
image: apache/kafka:3.9.0
29+
image: apache/kafka:${KAFKA_VERSION}
3030
container_name: controller-3
3131
environment:
3232
KAFKA_NODE_ID: 3
@@ -38,7 +38,7 @@ services:
3838
KAFKA_GROUP_INITIAL_REBALANCE_DELAY_MS: 0
3939

4040
broker-1:
41-
image: apache/kafka:3.9.0
41+
image: apache/kafka:${KAFKA_VERSION}
4242
container_name: broker-1
4343
ports:
4444
- 9092:9092
@@ -58,7 +58,7 @@ services:
5858
- controller-3
5959

6060
broker-2:
61-
image: apache/kafka:3.9.0
61+
image: apache/kafka:${KAFKA_VERSION}
6262
container_name: broker-2
6363
ports:
6464
- 9093:9092
@@ -78,7 +78,7 @@ services:
7878
- controller-3
7979

8080
broker-3:
81-
image: apache/kafka:3.9.0
81+
image: apache/kafka:${KAFKA_VERSION}
8282
container_name: broker-3
8383
ports:
8484
- 9094:9092

‎docker/compose-multiple.yml

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@
22

33
services:
44
controller-1:
5-
image: apache/kafka:3.9.0
5+
image: apache/kafka:${KAFKA_VERSION}
66
container_name: controller-1
77
environment:
88
_JAVA_OPTIONS: '-XX:UseSVE=0'
@@ -15,7 +15,7 @@ services:
1515
KAFKA_GROUP_INITIAL_REBALANCE_DELAY_MS: 0
1616

1717
controller-2:
18-
image: apache/kafka:3.9.0
18+
image: apache/kafka:${KAFKA_VERSION}
1919
container_name: controller-2
2020
environment:
2121
_JAVA_OPTIONS: '-XX:UseSVE=0'
@@ -28,7 +28,7 @@ services:
2828
KAFKA_GROUP_INITIAL_REBALANCE_DELAY_MS: 0
2929

3030
controller-3:
31-
image: apache/kafka:3.9.0
31+
image: apache/kafka:${KAFKA_VERSION}
3232
container_name: controller-3
3333
environment:
3434
_JAVA_OPTIONS: '-XX:UseSVE=0'
@@ -41,7 +41,7 @@ services:
4141
KAFKA_GROUP_INITIAL_REBALANCE_DELAY_MS: 0
4242

4343
broker-1:
44-
image: apache/kafka:3.9.0
44+
image: apache/kafka:${KAFKA_VERSION}
4545
container_name: broker-1
4646
ports:
4747
- 9092:9092
@@ -62,7 +62,7 @@ services:
6262
- controller-3
6363

6464
broker-2:
65-
image: apache/kafka:3.9.0
65+
image: apache/kafka:${KAFKA_VERSION}
6666
container_name: broker-2
6767
ports:
6868
- 3003:9092
@@ -83,7 +83,7 @@ services:
8383
- controller-3
8484

8585
broker-3:
86-
image: apache/kafka:3.9.0
86+
image: apache/kafka:${KAFKA_VERSION}
8787
container_name: broker-3
8888
ports:
8989
- 3004:9092

‎docker/compose-single.yml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@
22
---
33
services:
44
kafka:
5-
image: apache/kafka:3.9.0
5+
image: apache/kafka:${KAFKA_VERSION}
66
ports:
77
- '9092:9092' # PLAIN TEXT
88
- '9093:9093' # SSL

‎docs/diagnostic.md

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -66,6 +66,7 @@ Each tracing channel publishes events with the following common properties:
6666
| `plt:kafka:connections:connects` | `Connection` | Traces a connection attempt to a broker. |
6767
| `plt:kafka:connections:api` | `Connection` | Traces a low level API request. |
6868
| `plt:kafka:connections:pools:gets` | `ConnectionPool` | Traces a connection retrieval attempt from a connection pool. |
69+
| `plt:kafka:base:apis` | `Base` | Traces a `Base.listApis` request. |
6970
| `plt:kafka:base:metadata` | `Base` | Traces a `Base.metadata` request. |
7071
| `plt:kafka:admin:topics` | `Admin` | Traces a `Admin.createTopics` or `Admin.deleteTopics` request. |
7172
| `plt:kafka:admin:groups` | `Admin` | Traces a `Admin.listGroups`, `Admin.describeGroups` or `Admin.deleteGroups` request. |

‎package.json

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -44,7 +44,8 @@
4444
"ajv-errors": "^3.0.0",
4545
"debug": "^4.4.0",
4646
"fastq": "^1.19.1",
47-
"mnemonist": "^0.40.3"
47+
"mnemonist": "^0.40.3",
48+
"scule": "^1.3.0"
4849
},
4950
"optionalDependencies": {
5051
"lz4-napi": "^2.8.0",
@@ -67,11 +68,10 @@
6768
"parse5": "^7.2.1",
6869
"prettier": "^3.5.3",
6970
"prom-client": "^15.1.3",
70-
"scule": "^1.3.0",
7171
"semver": "^7.7.1",
7272
"typescript": "^5.7.3"
7373
},
7474
"engines": {
7575
"node": ">= 22.14.0"
7676
}
77-
}
77+
}

‎playground/apis/admin/acl.ts

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
1-
import { api as createAclsV3 } from '../../../src/apis/admin/create-acls.ts'
2-
import { api as deleteAclsV3 } from '../../../src/apis/admin/delete-acls.ts'
3-
import { api as describeAclsV3 } from '../../../src/apis/admin/describe-acls.ts'
1+
import { api as createAclsV3 } from '../../../src/apis/admin/create-acls-v3.ts'
2+
import { api as deleteAclsV3 } from '../../../src/apis/admin/delete-acls-v3.ts'
3+
import { api as describeAclsV3 } from '../../../src/apis/admin/describe-acls-v3.ts'
44
import {
55
AclOperations,
66
AclPermissionTypes,

‎playground/apis/admin/assignments.ts

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
1-
import { api as alterPartitionReassignmentsV0 } from '../../../src/apis/admin/alter-partition-reassignments.ts'
2-
import { api as listPartitionReassignmentsV0 } from '../../../src/apis/admin/list-partition-reassignments.ts'
1+
import { api as alterPartitionReassignmentsV0 } from '../../../src/apis/admin/alter-partition-reassignments-v0.ts'
2+
import { api as listPartitionReassignmentsV0 } from '../../../src/apis/admin/list-partition-reassignments-v0.ts'
33
import { Connection } from '../../../src/network/connection.ts'
44
import { performAPICallWithRetry } from '../../utils.ts'
55

‎playground/apis/admin/client-quotas.ts

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
1-
import { api as alterClientQuotasV1 } from '../../../src/apis/admin/alter-client-quotas.ts'
2-
import { api as describeClientQuotasV0 } from '../../../src/apis/admin/describe-client-quotas.ts'
1+
import { api as alterClientQuotasV1 } from '../../../src/apis/admin/alter-client-quotas-v1.ts'
2+
import { api as describeClientQuotasV0 } from '../../../src/apis/admin/describe-client-quotas-v0.ts'
33
import { ClientQuotaMatchTypes } from '../../../src/apis/enumerations.ts'
44
import { Connection } from '../../../src/network/connection.ts'
55
import { performAPICallWithRetry } from '../../utils.ts'

‎playground/apis/admin/config.ts

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
1-
import { api as alterConfigsV2 } from '../../../src/apis/admin/alter-configs.ts'
2-
import { api as describeConfigsV4 } from '../../../src/apis/admin/describe-configs.ts'
3-
import { api as incrementalAlterConfigsV1 } from '../../../src/apis/admin/incremental-alter-configs.ts'
1+
import { api as alterConfigsV2 } from '../../../src/apis/admin/alter-configs-v2.ts'
2+
import { api as describeConfigsV4 } from '../../../src/apis/admin/describe-configs-v4.ts'
3+
import { api as incrementalAlterConfigsV1 } from '../../../src/apis/admin/incremental-alter-configs-v1.ts'
44
import { IncrementalAlterConfigTypes, ResourceTypes } from '../../../src/apis/enumerations.ts'
55
import { Connection } from '../../../src/network/connection.ts'
66
import { performAPICallWithRetry } from '../../utils.ts'

‎playground/apis/admin/create-topics.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
import { api as createTopicsV7 } from '../../../src/apis/admin/create-topics.ts'
1+
import { api as createTopicsV7 } from '../../../src/apis/admin/create-topics-v7.ts'
22
import { Connection } from '../../../src/network/connection.ts'
33
import { performAPICallWithRetry } from '../../utils.ts'
44

‎playground/apis/admin/delete-records.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
import { api as deleteRecordsV2 } from '../../../src/apis/admin/delete-records.ts'
1+
import { api as deleteRecordsV2 } from '../../../src/apis/admin/delete-records-v2.ts'
22
import { Connection } from '../../../src/network/connection.ts'
33
import { performAPICallWithRetry } from '../../utils.ts'
44

‎playground/apis/admin/delete-topics.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
import { api as deleteTopicsV6 } from '../../../src/apis/admin/delete-topics.ts'
1+
import { api as deleteTopicsV6 } from '../../../src/apis/admin/delete-topics-v6.ts'
22
import { Connection } from '../../../src/network/connection.ts'
33
import { performAPICallWithRetry } from '../../utils.ts'
44

‎playground/apis/admin/group.ts

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,8 @@
1-
import { api as deleteGroupsV2 } from '../../../src/apis/admin/delete-groups.ts'
2-
import { api as describeGroupsV5 } from '../../../src/apis/admin/describe-groups.ts'
3-
import { api as listGroupsV5 } from '../../../src/apis/admin/list-groups.ts'
1+
import { api as deleteGroupsV2 } from '../../../src/apis/admin/delete-groups-v2.ts'
2+
import { api as describeGroupsV5 } from '../../../src/apis/admin/describe-groups-v5.ts'
3+
import { api as listGroupsV5 } from '../../../src/apis/admin/list-groups-v5.ts'
44
import { FindCoordinatorKeyTypes } from '../../../src/apis/enumerations.ts'
5-
import { api as findCoordinatorV6 } from '../../../src/apis/metadata/find-coordinator.ts'
5+
import { api as findCoordinatorV6 } from '../../../src/apis/metadata/find-coordinator-v6.ts'
66
import { Connection } from '../../../src/network/connection.ts'
77
import { performAPICallWithRetry } from '../../utils.ts'
88

‎playground/apis/admin/log-dirs.ts

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
1-
import { api as alterReplicaLogDirsV2 } from '../../../src/apis/admin/alter-replica-log-dirs.ts'
2-
import { api as describeLogDirsV4 } from '../../../src/apis/admin/describe-log-dirs.ts'
1+
import { api as alterReplicaLogDirsV2 } from '../../../src/apis/admin/alter-replica-log-dirs-v2.ts'
2+
import { api as describeLogDirsV4 } from '../../../src/apis/admin/describe-log-dirs-v4.ts'
33
import { Connection } from '../../../src/network/connection.ts'
44
import { performAPICallWithRetry } from '../../utils.ts'
55

‎playground/apis/admin/misc.ts

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -1,13 +1,13 @@
1-
import { api as consumerGroupDescribeV0 } from '../../../src/apis/admin/consumer-group-describe.ts'
2-
import { api as describeClusterV1 } from '../../../src/apis/admin/describe-cluster.ts'
3-
import { api as describeProducersV0 } from '../../../src/apis/admin/describe-producers.ts'
4-
import { api as describeQuorumV2 } from '../../../src/apis/admin/describe-quorum.ts'
5-
import { api as describeTopicPartitionsV0 } from '../../../src/apis/admin/describe-topic-partitions.ts'
6-
import { api as describeTransactionsV0 } from '../../../src/apis/admin/describe-transactions.ts'
7-
import { api as envelopeV0 } from '../../../src/apis/admin/envelope.ts'
8-
import { api as listTransactionsV0 } from '../../../src/apis/admin/list-transactions.ts'
9-
import { api as unregisterBrokerV0 } from '../../../src/apis/admin/unregister-broker.ts'
10-
import { api as updateFeaturesV1 } from '../../../src/apis/admin/update-features.ts'
1+
import { api as consumerGroupDescribeV0 } from '../../../src/apis/admin/consumer-group-describe-v0.ts'
2+
import { api as describeClusterV1 } from '../../../src/apis/admin/describe-cluster-v1.ts'
3+
import { api as describeProducersV0 } from '../../../src/apis/admin/describe-producers-v0.ts'
4+
import { api as describeQuorumV2 } from '../../../src/apis/admin/describe-quorum-v2.ts'
5+
import { api as describeTopicPartitionsV0 } from '../../../src/apis/admin/describe-topic-partitions-v0.ts'
6+
import { api as describeTransactionsV0 } from '../../../src/apis/admin/describe-transactions-v0.ts'
7+
import { api as envelopeV0 } from '../../../src/apis/admin/envelope-v0.ts'
8+
import { api as listTransactionsV0 } from '../../../src/apis/admin/list-transactions-v1.ts'
9+
import { api as unregisterBrokerV0 } from '../../../src/apis/admin/unregister-broker-v0.ts'
10+
import { api as updateFeaturesV1 } from '../../../src/apis/admin/update-features-v1.ts'
1111
import { DescribeClusterEndpointTypes, FeatureUpgradeTypes } from '../../../src/apis/enumerations.ts'
1212
import { Connection } from '../../../src/network/connection.ts'
1313
import { performAPICallWithRetry } from '../../utils.ts'

‎playground/apis/admin/offset-delete.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
import { api as offsetDeleteV0 } from '../../../src/apis/admin/offset-delete.ts'
1+
import { api as offsetDeleteV0 } from '../../../src/apis/admin/offset-delete-v0.ts'
22
import { Connection } from '../../../src/network/connection.ts'
33
import { performAPICallWithRetry } from '../../utils.ts'
44

‎playground/apis/admin/partitions.ts

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
1-
import { api as alterPartitionV3 } from '../../../src/apis/admin/alter-partition.ts'
2-
import { api as createPartitionsV3 } from '../../../src/apis/admin/create-partitions.ts'
1+
import { api as alterPartitionV3 } from '../../../src/apis/admin/alter-partition-v3.ts'
2+
import { api as createPartitionsV3 } from '../../../src/apis/admin/create-partitions-v3.ts'
33
import { Connection } from '../../../src/network/connection.ts'
44
import { performAPICallWithRetry } from '../../utils.ts'
55

‎playground/apis/admin/scram.ts

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
1-
import { api as alterUserScramCredentialsV0 } from '../../../src/apis/admin/alter-user-scram-credentials.ts'
2-
import { api as describeUserScramCredentialsV0 } from '../../../src/apis/admin/describe-user-scram-credentials.ts'
1+
import { api as alterUserScramCredentialsV0 } from '../../../src/apis/admin/alter-user-scram-credentials-v0.ts'
2+
import { api as describeUserScramCredentialsV0 } from '../../../src/apis/admin/describe-user-scram-credentials-v0.ts'
33
import { ScramMechanisms } from '../../../src/apis/enumerations.ts'
44
import { Connection } from '../../../src/network/connection.ts'
55
import { performAPICallWithRetry } from '../../utils.ts'

‎playground/apis/consumer/fetch.ts

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1,10 +1,10 @@
1-
import { api as fetchV17 } from '../../../src/apis/consumer/fetch.ts'
2-
import { api as offsetCommitV9 } from '../../../src/apis/consumer/offset-commit.ts'
3-
import { api as offsetFetchV9 } from '../../../src/apis/consumer/offset-fetch.ts'
4-
import { api as syncGroupV5 } from '../../../src/apis/consumer/sync-group.ts'
1+
import { api as fetchV17 } from '../../../src/apis/consumer/fetch-v17.ts'
2+
import { api as offsetCommitV9 } from '../../../src/apis/consumer/offset-commit-v9.ts'
3+
import { api as offsetFetchV9 } from '../../../src/apis/consumer/offset-fetch-v9.ts'
4+
import { api as syncGroupV5 } from '../../../src/apis/consumer/sync-group-v5.ts'
55
import { FetchIsolationLevels, FindCoordinatorKeyTypes } from '../../../src/apis/enumerations.ts'
6-
import { api as findCoordinatorV6 } from '../../../src/apis/metadata/find-coordinator.ts'
7-
import { api as metadataV12 } from '../../../src/apis/metadata/metadata.ts'
6+
import { api as findCoordinatorV6 } from '../../../src/apis/metadata/find-coordinator-v6.ts'
7+
import { api as metadataV12 } from '../../../src/apis/metadata/metadata-v12.ts'
88
import { Connection } from '../../../src/network/connection.ts'
99
import { joinGroup, performAPICallWithRetry } from '../../utils.ts'
1010

‎playground/apis/consumer/group.ts

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,9 @@
1-
import { api as consumerGroupHeartbeatV0 } from '../../../src/apis/consumer/consumer-group-heartbeat.ts'
2-
import { api as heartbeatV4 } from '../../../src/apis/consumer/heartbeat.ts'
3-
import { api as leaveGroupV5 } from '../../../src/apis/consumer/leave-group.ts'
4-
import { api as syncGroupV5 } from '../../../src/apis/consumer/sync-group.ts'
1+
import { api as consumerGroupHeartbeatV0 } from '../../../src/apis/consumer/consumer-group-heartbeat-v0.ts'
2+
import { api as heartbeatV4 } from '../../../src/apis/consumer/heartbeat-v4.ts'
3+
import { api as leaveGroupV5 } from '../../../src/apis/consumer/leave-group-v5.ts'
4+
import { api as syncGroupV5 } from '../../../src/apis/consumer/sync-group-v5.ts'
55
import { FindCoordinatorKeyTypes } from '../../../src/apis/enumerations.ts'
6-
import { api as findCoordinatorV6 } from '../../../src/apis/metadata/find-coordinator.ts'
6+
import { api as findCoordinatorV6 } from '../../../src/apis/metadata/find-coordinator-v6.ts'
77
import { Connection } from '../../../src/network/connection.ts'
88
import { joinGroup, performAPICallWithRetry } from '../../utils.ts'
99

‎playground/apis/consumer/list-offsets.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
import { api as listOffsetsV9 } from '../../../src/apis/consumer/list-offsets.ts'
1+
import { api as listOffsetsV9 } from '../../../src/apis/consumer/list-offsets-v9.ts'
22
import { Connection } from '../../../src/network/connection.ts'
33
import { performAPICallWithRetry } from '../../utils.ts'
44

‎playground/apis/metadata/api-versions.ts

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
import { api as apiVersionsV4 } from '../../../src/apis/metadata/api-versions.ts'
1+
import { api as apiVersionsV3 } from '../../../src/apis/metadata/api-versions-v3.ts'
22
import { Connection } from '../../../src/network/connection.ts'
33
import { performAPICallWithRetry } from '../../utils.ts'
44

@@ -11,6 +11,6 @@ const connection = new Connection('123', {
1111
})
1212
await connection.connect('localhost', 9092)
1313

14-
await performAPICallWithRetry('ApiVersions', () => apiVersionsV4.async(connection, 'kafka', '1.0.0'))
14+
await performAPICallWithRetry('ApiVersions', () => apiVersionsV3.async(connection, 'kafka', '1.0.0'))
1515

1616
await connection.close()

‎playground/apis/metadata/find-coordinator.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
import { FindCoordinatorKeyTypes } from '../../../src/apis/enumerations.ts'
2-
import { api as findCoordinatorV6 } from '../../../src/apis/metadata/find-coordinator.ts'
2+
import { api as findCoordinatorV6 } from '../../../src/apis/metadata/find-coordinator-v6.ts'
33
import { Connection } from '../../../src/network/connection.ts'
44
import { performAPICallWithRetry } from '../../utils.ts'
55

‎playground/apis/metadata/metadata.ts

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
1-
import { api as metadataV12 } from '../../../src/apis/metadata/metadata.ts'
2-
import { api as saslAuthenticateV2 } from '../../../src/apis/security/sasl-authenticate.ts'
3-
import { api as saslHandshakeV1 } from '../../../src/apis/security/sasl-handshake.ts'
1+
import { api as metadataV12 } from '../../../src/apis/metadata/metadata-v12.ts'
2+
import { api as saslAuthenticateV2 } from '../../../src/apis/security/sasl-authenticate-v2.ts'
3+
import { api as saslHandshakeV1 } from '../../../src/apis/security/sasl-handshake-v1.ts'
44
import { Connection } from '../../../src/network/connection.ts'
55
import { authenticate } from '../../../src/protocol/sasl/scram-sha.ts'
66
import { performAPICallWithRetry } from '../../utils.ts'

‎playground/apis/producer/init-producer-id.ts

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
import { FindCoordinatorKeyTypes } from '../../../src/apis/enumerations.ts'
2-
import { api as findCoordinatorV6 } from '../../../src/apis/metadata/find-coordinator.ts'
3-
import { api as initProducerIdV5 } from '../../../src/apis/producer/init-producer-id.ts'
2+
import { api as findCoordinatorV6 } from '../../../src/apis/metadata/find-coordinator-v6.ts'
3+
import { api as initProducerIdV5 } from '../../../src/apis/producer/init-producer-id-v5.ts'
44
import { Connection } from '../../../src/network/connection.ts'
55
import { performAPICallWithRetry } from '../../utils.ts'
66

‎playground/apis/producer/produce-idempotent.ts

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
1-
import { api as initProducerIdV5 } from '../../../src/apis/producer/init-producer-id.ts'
2-
import { api as produceV11 } from '../../../src/apis/producer/produce.ts'
1+
import { api as initProducerIdV5 } from '../../../src/apis/producer/init-producer-id-v5.ts'
2+
import { api as produceV11 } from '../../../src/apis/producer/produce-v11.ts'
33
import { Connection } from '../../../src/network/connection.ts'
44
import { performAPICallWithRetry } from '../../utils.ts'
55

0 commit comments

Comments
 (0)