diff --git a/baseline_api_notes b/baseline_api_notes new file mode 100644 index 000000000..4e0c5c91d --- /dev/null +++ b/baseline_api_notes @@ -0,0 +1,98 @@ +# Discussion here: https://issues.apache.org/jira/browse/KAFKA-18648 + +Produce (0): +current: 7 / 2.1 baseline! +2.1 => 7 +3.0 => 9 +3.9 => 11 +kafka/producer/sender.py: version = self._client.api_version(ProduceRequest, max_version=7) + +Fetch (1): +current: 10 / 2.1 baseline! +2.1 => 10 +3.0 => 12 +3.9 => 17 +kafka/consumer/fetcher.py: version = self._client.api_version(FetchRequest, max_version=10) +# Still need log truncation KAFKA-7747 (enabled in v9, recommended for v11 per https://github.com/tulios/kafkajs/issues/1464) + +ListOffsets (2): +current: 4 / 2.1 baseline! +2.1 => 4 +3.0 => 7 +3.9 => 9 +kafka/consumer/fetcher.py: version = self._client.api_version(ListOffsetsRequest, max_version=4) + +Metadata (3): +current: 7 / 2.1 baseline! +2.1 => 7 +3.0 => 11 +3.9 => 12 +kafka/client_async.py: api_version = self.api_version(MetadataRequest, max_version=7) + +OffsetCommit (8): +current: 7 / 2.1 baseline! +2.1 => 6 +3.0 => 8 +3.9 => 9 +kafka/coordinator/consumer.py: version = self._client.api_version(OffsetCommitRequest, max_version=7) + +OffsetFetch (9): +current: 5 / 2.1 baseline! +2.1 => 5 +3.0 => 8 +3.9 => 9 +kafka/coordinator/consumer.py: version = self._client.api_version(OffsetFetchRequest, max_version=5) + +FindCoordinator(10): +current: 2 / 2.1 baseline! +2.1 => 2 +3.0 => 4 +3.9 => 6 +kafka/coordinator/base.py: version = self._client.api_version(FindCoordinatorRequest, max_version=2) + +JoinGroup(11): +current: 5 / 2.1 baseline! +2.1 => 3 +3.0 => 7 +3.9 => 9 +kafka/coordinator/base.py: version = self._client.api_version(JoinGroupRequest, max_version=5) + +Heartbeat (12) +current: 3 / 2.1 baseline! +2.1 => 2 +3.0 => 4 +3.9 => 4 +kafka/coordinator/base.py: version = self._client.api_version(HeartbeatRequest, max_version=3) + +LeaveGroup (13): +current: 3 / 2.1 baseline! +2.1 => 2 +3.0 => 4 +3.9 => 5 +kafka/coordinator/base.py: version = self._client.api_version(LeaveGroupRequest, max_version=3) + +SyncGroup (14): +current: 3 / 2.1 baseline! +2.1 => 2 +3.0 => 5 +3.9 => 5 +kafka/coordinator/base.py: version = self._client.api_version(SyncGroupRequest, max_version=3) +kafka/coordinator/base.py: version = self._client.api_version(SyncGroupRequest, max_version=3) + +ApiVersions (18): +current: 4 / 3.9 baseline! +2.1 => 2 +3.0 => 3 +3.9 => 4 + +SaslHandshake (17): +current: 1 / 3.9 baseline! +2.1 => 1 +3.0 => 1 +3.9 => 1 + +SaslAuthenticate (36): +current: 0 / 2.1 baseline! +2.1 => 0 +3.0 => 2 +3.9 => 2