diff --git a/src/kio/schema/fetch/v0/response.py b/src/kio/schema/fetch/v0/response.py index 88e2830a..47c94cf3 100644 --- a/src/kio/schema/fetch/v0/response.py +++ b/src/kio/schema/fetch/v0/response.py @@ -12,6 +12,7 @@ from kio.schema.types import TopicName from kio.static.constants import EntityType from kio.static.constants import ErrorCode +from kio.static.primitive import Records from kio.static.primitive import i16 from kio.static.primitive import i32 from kio.static.primitive import i64 @@ -30,7 +31,7 @@ class PartitionData: """The error code, or 0 if there was no fetch error.""" high_watermark: i64 = field(metadata={"kafka_type": "int64"}) """The current high water mark.""" - records: bytes | None = field(metadata={"kafka_type": "records"}) + records: Records | None = field(metadata={"kafka_type": "records"}) """The record data.""" diff --git a/src/kio/schema/fetch/v1/response.py b/src/kio/schema/fetch/v1/response.py index 1ad1f353..618ba94e 100644 --- a/src/kio/schema/fetch/v1/response.py +++ b/src/kio/schema/fetch/v1/response.py @@ -12,6 +12,7 @@ from kio.schema.types import TopicName from kio.static.constants import EntityType from kio.static.constants import ErrorCode +from kio.static.primitive import Records from kio.static.primitive import i16 from kio.static.primitive import i32 from kio.static.primitive import i32Timedelta @@ -31,7 +32,7 @@ class PartitionData: """The error code, or 0 if there was no fetch error.""" high_watermark: i64 = field(metadata={"kafka_type": "int64"}) """The current high water mark.""" - records: bytes | None = field(metadata={"kafka_type": "records"}) + records: Records | None = field(metadata={"kafka_type": "records"}) """The record data.""" diff --git a/src/kio/schema/fetch/v10/response.py b/src/kio/schema/fetch/v10/response.py index a8960851..2c9cd75d 100644 --- a/src/kio/schema/fetch/v10/response.py +++ b/src/kio/schema/fetch/v10/response.py @@ -13,6 +13,7 @@ from kio.schema.types import TopicName from kio.static.constants import EntityType from kio.static.constants import ErrorCode +from kio.static.primitive import Records from kio.static.primitive import i16 from kio.static.primitive import i32 from kio.static.primitive import i32Timedelta @@ -51,7 +52,7 @@ class PartitionData: """The current log start offset.""" aborted_transactions: tuple[AbortedTransaction, ...] | None """The aborted transactions.""" - records: bytes | None = field(metadata={"kafka_type": "records"}) + records: Records | None = field(metadata={"kafka_type": "records"}) """The record data.""" diff --git a/src/kio/schema/fetch/v11/response.py b/src/kio/schema/fetch/v11/response.py index 03b91a5b..e0721e21 100644 --- a/src/kio/schema/fetch/v11/response.py +++ b/src/kio/schema/fetch/v11/response.py @@ -14,6 +14,7 @@ from kio.schema.types import TopicName from kio.static.constants import EntityType from kio.static.constants import ErrorCode +from kio.static.primitive import Records from kio.static.primitive import i16 from kio.static.primitive import i32 from kio.static.primitive import i32Timedelta @@ -56,7 +57,7 @@ class PartitionData: metadata={"kafka_type": "int32"}, default=BrokerId(-1) ) """The preferred read replica for the consumer to use on its next fetch request""" - records: bytes | None = field(metadata={"kafka_type": "records"}) + records: Records | None = field(metadata={"kafka_type": "records"}) """The record data.""" diff --git a/src/kio/schema/fetch/v12/response.py b/src/kio/schema/fetch/v12/response.py index ef3b43ef..2fe05da6 100644 --- a/src/kio/schema/fetch/v12/response.py +++ b/src/kio/schema/fetch/v12/response.py @@ -14,6 +14,7 @@ from kio.schema.types import TopicName from kio.static.constants import EntityType from kio.static.constants import ErrorCode +from kio.static.primitive import Records from kio.static.primitive import i16 from kio.static.primitive import i32 from kio.static.primitive import i32Timedelta @@ -100,7 +101,7 @@ class PartitionData: metadata={"kafka_type": "int32"}, default=BrokerId(-1) ) """The preferred read replica for the consumer to use on its next fetch request""" - records: bytes | None = field(metadata={"kafka_type": "records"}) + records: Records | None = field(metadata={"kafka_type": "records"}) """The record data.""" diff --git a/src/kio/schema/fetch/v13/response.py b/src/kio/schema/fetch/v13/response.py index 183f2ee9..8f5e7424 100644 --- a/src/kio/schema/fetch/v13/response.py +++ b/src/kio/schema/fetch/v13/response.py @@ -15,6 +15,7 @@ from kio.schema.types import ProducerId from kio.static.constants import EntityType from kio.static.constants import ErrorCode +from kio.static.primitive import Records from kio.static.primitive import i16 from kio.static.primitive import i32 from kio.static.primitive import i32Timedelta @@ -101,7 +102,7 @@ class PartitionData: metadata={"kafka_type": "int32"}, default=BrokerId(-1) ) """The preferred read replica for the consumer to use on its next fetch request""" - records: bytes | None = field(metadata={"kafka_type": "records"}) + records: Records | None = field(metadata={"kafka_type": "records"}) """The record data.""" diff --git a/src/kio/schema/fetch/v14/response.py b/src/kio/schema/fetch/v14/response.py index b613dbde..5186083b 100644 --- a/src/kio/schema/fetch/v14/response.py +++ b/src/kio/schema/fetch/v14/response.py @@ -15,6 +15,7 @@ from kio.schema.types import ProducerId from kio.static.constants import EntityType from kio.static.constants import ErrorCode +from kio.static.primitive import Records from kio.static.primitive import i16 from kio.static.primitive import i32 from kio.static.primitive import i32Timedelta @@ -101,7 +102,7 @@ class PartitionData: metadata={"kafka_type": "int32"}, default=BrokerId(-1) ) """The preferred read replica for the consumer to use on its next fetch request""" - records: bytes | None = field(metadata={"kafka_type": "records"}) + records: Records | None = field(metadata={"kafka_type": "records"}) """The record data.""" diff --git a/src/kio/schema/fetch/v15/response.py b/src/kio/schema/fetch/v15/response.py index 8ca5689a..c37ee1d2 100644 --- a/src/kio/schema/fetch/v15/response.py +++ b/src/kio/schema/fetch/v15/response.py @@ -15,6 +15,7 @@ from kio.schema.types import ProducerId from kio.static.constants import EntityType from kio.static.constants import ErrorCode +from kio.static.primitive import Records from kio.static.primitive import i16 from kio.static.primitive import i32 from kio.static.primitive import i32Timedelta @@ -101,7 +102,7 @@ class PartitionData: metadata={"kafka_type": "int32"}, default=BrokerId(-1) ) """The preferred read replica for the consumer to use on its next fetch request""" - records: bytes | None = field(metadata={"kafka_type": "records"}) + records: Records | None = field(metadata={"kafka_type": "records"}) """The record data.""" diff --git a/src/kio/schema/fetch/v2/response.py b/src/kio/schema/fetch/v2/response.py index bcc8bc5f..f2fa0476 100644 --- a/src/kio/schema/fetch/v2/response.py +++ b/src/kio/schema/fetch/v2/response.py @@ -12,6 +12,7 @@ from kio.schema.types import TopicName from kio.static.constants import EntityType from kio.static.constants import ErrorCode +from kio.static.primitive import Records from kio.static.primitive import i16 from kio.static.primitive import i32 from kio.static.primitive import i32Timedelta @@ -31,7 +32,7 @@ class PartitionData: """The error code, or 0 if there was no fetch error.""" high_watermark: i64 = field(metadata={"kafka_type": "int64"}) """The current high water mark.""" - records: bytes | None = field(metadata={"kafka_type": "records"}) + records: Records | None = field(metadata={"kafka_type": "records"}) """The record data.""" diff --git a/src/kio/schema/fetch/v3/response.py b/src/kio/schema/fetch/v3/response.py index 83711e3c..3fe305b4 100644 --- a/src/kio/schema/fetch/v3/response.py +++ b/src/kio/schema/fetch/v3/response.py @@ -12,6 +12,7 @@ from kio.schema.types import TopicName from kio.static.constants import EntityType from kio.static.constants import ErrorCode +from kio.static.primitive import Records from kio.static.primitive import i16 from kio.static.primitive import i32 from kio.static.primitive import i32Timedelta @@ -31,7 +32,7 @@ class PartitionData: """The error code, or 0 if there was no fetch error.""" high_watermark: i64 = field(metadata={"kafka_type": "int64"}) """The current high water mark.""" - records: bytes | None = field(metadata={"kafka_type": "records"}) + records: Records | None = field(metadata={"kafka_type": "records"}) """The record data.""" diff --git a/src/kio/schema/fetch/v4/response.py b/src/kio/schema/fetch/v4/response.py index 4b632193..b9737fc4 100644 --- a/src/kio/schema/fetch/v4/response.py +++ b/src/kio/schema/fetch/v4/response.py @@ -13,6 +13,7 @@ from kio.schema.types import TopicName from kio.static.constants import EntityType from kio.static.constants import ErrorCode +from kio.static.primitive import Records from kio.static.primitive import i16 from kio.static.primitive import i32 from kio.static.primitive import i32Timedelta @@ -49,7 +50,7 @@ class PartitionData: """The last stable offset (or LSO) of the partition. This is the last offset such that the state of all transactional records prior to this offset have been decided (ABORTED or COMMITTED)""" aborted_transactions: tuple[AbortedTransaction, ...] | None """The aborted transactions.""" - records: bytes | None = field(metadata={"kafka_type": "records"}) + records: Records | None = field(metadata={"kafka_type": "records"}) """The record data.""" diff --git a/src/kio/schema/fetch/v5/response.py b/src/kio/schema/fetch/v5/response.py index 2aca9c50..820a33e2 100644 --- a/src/kio/schema/fetch/v5/response.py +++ b/src/kio/schema/fetch/v5/response.py @@ -13,6 +13,7 @@ from kio.schema.types import TopicName from kio.static.constants import EntityType from kio.static.constants import ErrorCode +from kio.static.primitive import Records from kio.static.primitive import i16 from kio.static.primitive import i32 from kio.static.primitive import i32Timedelta @@ -51,7 +52,7 @@ class PartitionData: """The current log start offset.""" aborted_transactions: tuple[AbortedTransaction, ...] | None """The aborted transactions.""" - records: bytes | None = field(metadata={"kafka_type": "records"}) + records: Records | None = field(metadata={"kafka_type": "records"}) """The record data.""" diff --git a/src/kio/schema/fetch/v6/response.py b/src/kio/schema/fetch/v6/response.py index 3d19e836..bf939ca4 100644 --- a/src/kio/schema/fetch/v6/response.py +++ b/src/kio/schema/fetch/v6/response.py @@ -13,6 +13,7 @@ from kio.schema.types import TopicName from kio.static.constants import EntityType from kio.static.constants import ErrorCode +from kio.static.primitive import Records from kio.static.primitive import i16 from kio.static.primitive import i32 from kio.static.primitive import i32Timedelta @@ -51,7 +52,7 @@ class PartitionData: """The current log start offset.""" aborted_transactions: tuple[AbortedTransaction, ...] | None """The aborted transactions.""" - records: bytes | None = field(metadata={"kafka_type": "records"}) + records: Records | None = field(metadata={"kafka_type": "records"}) """The record data.""" diff --git a/src/kio/schema/fetch/v7/response.py b/src/kio/schema/fetch/v7/response.py index 70853670..d7042e90 100644 --- a/src/kio/schema/fetch/v7/response.py +++ b/src/kio/schema/fetch/v7/response.py @@ -13,6 +13,7 @@ from kio.schema.types import TopicName from kio.static.constants import EntityType from kio.static.constants import ErrorCode +from kio.static.primitive import Records from kio.static.primitive import i16 from kio.static.primitive import i32 from kio.static.primitive import i32Timedelta @@ -51,7 +52,7 @@ class PartitionData: """The current log start offset.""" aborted_transactions: tuple[AbortedTransaction, ...] | None """The aborted transactions.""" - records: bytes | None = field(metadata={"kafka_type": "records"}) + records: Records | None = field(metadata={"kafka_type": "records"}) """The record data.""" diff --git a/src/kio/schema/fetch/v8/response.py b/src/kio/schema/fetch/v8/response.py index 1f8acae8..8029c678 100644 --- a/src/kio/schema/fetch/v8/response.py +++ b/src/kio/schema/fetch/v8/response.py @@ -13,6 +13,7 @@ from kio.schema.types import TopicName from kio.static.constants import EntityType from kio.static.constants import ErrorCode +from kio.static.primitive import Records from kio.static.primitive import i16 from kio.static.primitive import i32 from kio.static.primitive import i32Timedelta @@ -51,7 +52,7 @@ class PartitionData: """The current log start offset.""" aborted_transactions: tuple[AbortedTransaction, ...] | None """The aborted transactions.""" - records: bytes | None = field(metadata={"kafka_type": "records"}) + records: Records | None = field(metadata={"kafka_type": "records"}) """The record data.""" diff --git a/src/kio/schema/fetch/v9/response.py b/src/kio/schema/fetch/v9/response.py index 19cc2eac..4fd88efb 100644 --- a/src/kio/schema/fetch/v9/response.py +++ b/src/kio/schema/fetch/v9/response.py @@ -13,6 +13,7 @@ from kio.schema.types import TopicName from kio.static.constants import EntityType from kio.static.constants import ErrorCode +from kio.static.primitive import Records from kio.static.primitive import i16 from kio.static.primitive import i32 from kio.static.primitive import i32Timedelta @@ -51,7 +52,7 @@ class PartitionData: """The current log start offset.""" aborted_transactions: tuple[AbortedTransaction, ...] | None """The aborted transactions.""" - records: bytes | None = field(metadata={"kafka_type": "records"}) + records: Records | None = field(metadata={"kafka_type": "records"}) """The record data.""" diff --git a/src/kio/schema/fetch_snapshot/v0/response.py b/src/kio/schema/fetch_snapshot/v0/response.py index 173e528c..ff89e277 100644 --- a/src/kio/schema/fetch_snapshot/v0/response.py +++ b/src/kio/schema/fetch_snapshot/v0/response.py @@ -13,6 +13,7 @@ from kio.schema.types import TopicName from kio.static.constants import EntityType from kio.static.constants import ErrorCode +from kio.static.primitive import Records from kio.static.primitive import i16 from kio.static.primitive import i32 from kio.static.primitive import i32Timedelta @@ -61,7 +62,7 @@ class PartitionSnapshot: """The total size of the snapshot.""" position: i64 = field(metadata={"kafka_type": "int64"}) """The starting byte position within the snapshot included in the Bytes field.""" - unaligned_records: bytes = field(metadata={"kafka_type": "records"}) + unaligned_records: Records = field(metadata={"kafka_type": "records"}) """Snapshot data in records format which may not be aligned on an offset boundary""" diff --git a/src/kio/schema/produce/v0/request.py b/src/kio/schema/produce/v0/request.py index 08c7bedd..66cdbbf0 100644 --- a/src/kio/schema/produce/v0/request.py +++ b/src/kio/schema/produce/v0/request.py @@ -11,6 +11,7 @@ from kio.schema.request_header.v1.header import RequestHeader from kio.schema.types import TopicName from kio.static.constants import EntityType +from kio.static.primitive import Records from kio.static.primitive import i16 from kio.static.primitive import i32 from kio.static.primitive import i32Timedelta @@ -25,7 +26,7 @@ class PartitionProduceData: __header_schema__: ClassVar[type[RequestHeader]] = RequestHeader index: i32 = field(metadata={"kafka_type": "int32"}) """The partition index.""" - records: bytes | None = field(metadata={"kafka_type": "records"}) + records: Records | None = field(metadata={"kafka_type": "records"}) """The record data to be produced.""" diff --git a/src/kio/schema/produce/v1/request.py b/src/kio/schema/produce/v1/request.py index 56af3146..5be4eac8 100644 --- a/src/kio/schema/produce/v1/request.py +++ b/src/kio/schema/produce/v1/request.py @@ -11,6 +11,7 @@ from kio.schema.request_header.v1.header import RequestHeader from kio.schema.types import TopicName from kio.static.constants import EntityType +from kio.static.primitive import Records from kio.static.primitive import i16 from kio.static.primitive import i32 from kio.static.primitive import i32Timedelta @@ -25,7 +26,7 @@ class PartitionProduceData: __header_schema__: ClassVar[type[RequestHeader]] = RequestHeader index: i32 = field(metadata={"kafka_type": "int32"}) """The partition index.""" - records: bytes | None = field(metadata={"kafka_type": "records"}) + records: Records | None = field(metadata={"kafka_type": "records"}) """The record data to be produced.""" diff --git a/src/kio/schema/produce/v2/request.py b/src/kio/schema/produce/v2/request.py index 5d87940e..6676a547 100644 --- a/src/kio/schema/produce/v2/request.py +++ b/src/kio/schema/produce/v2/request.py @@ -11,6 +11,7 @@ from kio.schema.request_header.v1.header import RequestHeader from kio.schema.types import TopicName from kio.static.constants import EntityType +from kio.static.primitive import Records from kio.static.primitive import i16 from kio.static.primitive import i32 from kio.static.primitive import i32Timedelta @@ -25,7 +26,7 @@ class PartitionProduceData: __header_schema__: ClassVar[type[RequestHeader]] = RequestHeader index: i32 = field(metadata={"kafka_type": "int32"}) """The partition index.""" - records: bytes | None = field(metadata={"kafka_type": "records"}) + records: Records | None = field(metadata={"kafka_type": "records"}) """The record data to be produced.""" diff --git a/src/kio/schema/produce/v3/request.py b/src/kio/schema/produce/v3/request.py index 6427877f..2d25ce4d 100644 --- a/src/kio/schema/produce/v3/request.py +++ b/src/kio/schema/produce/v3/request.py @@ -12,6 +12,7 @@ from kio.schema.types import TopicName from kio.schema.types import TransactionalId from kio.static.constants import EntityType +from kio.static.primitive import Records from kio.static.primitive import i16 from kio.static.primitive import i32 from kio.static.primitive import i32Timedelta @@ -26,7 +27,7 @@ class PartitionProduceData: __header_schema__: ClassVar[type[RequestHeader]] = RequestHeader index: i32 = field(metadata={"kafka_type": "int32"}) """The partition index.""" - records: bytes | None = field(metadata={"kafka_type": "records"}) + records: Records | None = field(metadata={"kafka_type": "records"}) """The record data to be produced.""" diff --git a/src/kio/schema/produce/v4/request.py b/src/kio/schema/produce/v4/request.py index faafe96c..1e925e3c 100644 --- a/src/kio/schema/produce/v4/request.py +++ b/src/kio/schema/produce/v4/request.py @@ -12,6 +12,7 @@ from kio.schema.types import TopicName from kio.schema.types import TransactionalId from kio.static.constants import EntityType +from kio.static.primitive import Records from kio.static.primitive import i16 from kio.static.primitive import i32 from kio.static.primitive import i32Timedelta @@ -26,7 +27,7 @@ class PartitionProduceData: __header_schema__: ClassVar[type[RequestHeader]] = RequestHeader index: i32 = field(metadata={"kafka_type": "int32"}) """The partition index.""" - records: bytes | None = field(metadata={"kafka_type": "records"}) + records: Records | None = field(metadata={"kafka_type": "records"}) """The record data to be produced.""" diff --git a/src/kio/schema/produce/v5/request.py b/src/kio/schema/produce/v5/request.py index f24ba6b7..c2a54974 100644 --- a/src/kio/schema/produce/v5/request.py +++ b/src/kio/schema/produce/v5/request.py @@ -12,6 +12,7 @@ from kio.schema.types import TopicName from kio.schema.types import TransactionalId from kio.static.constants import EntityType +from kio.static.primitive import Records from kio.static.primitive import i16 from kio.static.primitive import i32 from kio.static.primitive import i32Timedelta @@ -26,7 +27,7 @@ class PartitionProduceData: __header_schema__: ClassVar[type[RequestHeader]] = RequestHeader index: i32 = field(metadata={"kafka_type": "int32"}) """The partition index.""" - records: bytes | None = field(metadata={"kafka_type": "records"}) + records: Records | None = field(metadata={"kafka_type": "records"}) """The record data to be produced.""" diff --git a/src/kio/schema/produce/v6/request.py b/src/kio/schema/produce/v6/request.py index 3c2d1e2c..6e052883 100644 --- a/src/kio/schema/produce/v6/request.py +++ b/src/kio/schema/produce/v6/request.py @@ -12,6 +12,7 @@ from kio.schema.types import TopicName from kio.schema.types import TransactionalId from kio.static.constants import EntityType +from kio.static.primitive import Records from kio.static.primitive import i16 from kio.static.primitive import i32 from kio.static.primitive import i32Timedelta @@ -26,7 +27,7 @@ class PartitionProduceData: __header_schema__: ClassVar[type[RequestHeader]] = RequestHeader index: i32 = field(metadata={"kafka_type": "int32"}) """The partition index.""" - records: bytes | None = field(metadata={"kafka_type": "records"}) + records: Records | None = field(metadata={"kafka_type": "records"}) """The record data to be produced.""" diff --git a/src/kio/schema/produce/v7/request.py b/src/kio/schema/produce/v7/request.py index 37286810..cacd406a 100644 --- a/src/kio/schema/produce/v7/request.py +++ b/src/kio/schema/produce/v7/request.py @@ -12,6 +12,7 @@ from kio.schema.types import TopicName from kio.schema.types import TransactionalId from kio.static.constants import EntityType +from kio.static.primitive import Records from kio.static.primitive import i16 from kio.static.primitive import i32 from kio.static.primitive import i32Timedelta @@ -26,7 +27,7 @@ class PartitionProduceData: __header_schema__: ClassVar[type[RequestHeader]] = RequestHeader index: i32 = field(metadata={"kafka_type": "int32"}) """The partition index.""" - records: bytes | None = field(metadata={"kafka_type": "records"}) + records: Records | None = field(metadata={"kafka_type": "records"}) """The record data to be produced.""" diff --git a/src/kio/schema/produce/v8/request.py b/src/kio/schema/produce/v8/request.py index bf2396c1..88821d7f 100644 --- a/src/kio/schema/produce/v8/request.py +++ b/src/kio/schema/produce/v8/request.py @@ -12,6 +12,7 @@ from kio.schema.types import TopicName from kio.schema.types import TransactionalId from kio.static.constants import EntityType +from kio.static.primitive import Records from kio.static.primitive import i16 from kio.static.primitive import i32 from kio.static.primitive import i32Timedelta @@ -26,7 +27,7 @@ class PartitionProduceData: __header_schema__: ClassVar[type[RequestHeader]] = RequestHeader index: i32 = field(metadata={"kafka_type": "int32"}) """The partition index.""" - records: bytes | None = field(metadata={"kafka_type": "records"}) + records: Records | None = field(metadata={"kafka_type": "records"}) """The record data to be produced.""" diff --git a/src/kio/schema/produce/v9/request.py b/src/kio/schema/produce/v9/request.py index 1d6ab267..9278ee74 100644 --- a/src/kio/schema/produce/v9/request.py +++ b/src/kio/schema/produce/v9/request.py @@ -12,6 +12,7 @@ from kio.schema.types import TopicName from kio.schema.types import TransactionalId from kio.static.constants import EntityType +from kio.static.primitive import Records from kio.static.primitive import i16 from kio.static.primitive import i32 from kio.static.primitive import i32Timedelta @@ -26,7 +27,7 @@ class PartitionProduceData: __header_schema__: ClassVar[type[RequestHeader]] = RequestHeader index: i32 = field(metadata={"kafka_type": "int32"}) """The partition index.""" - records: bytes | None = field(metadata={"kafka_type": "records"}) + records: Records | None = field(metadata={"kafka_type": "records"}) """The record data to be produced.""" diff --git a/tests/generated/test_fetch_snapshot_v0_response.py b/tests/generated/test_fetch_snapshot_v0_response.py index 4476a541..0b593bc4 100644 --- a/tests/generated/test_fetch_snapshot_v0_response.py +++ b/tests/generated/test_fetch_snapshot_v0_response.py @@ -14,6 +14,7 @@ from kio.schema.fetch_snapshot.v0.response import TopicSnapshot from kio.serial import entity_reader from kio.serial import entity_writer +from tests.conftest import JavaTester from tests.conftest import setup_buffer read_snapshot_id: Final = entity_reader(SnapshotId) @@ -84,3 +85,11 @@ def test_fetch_snapshot_response_roundtrip(instance: FetchSnapshotResponse) -> N buffer.seek(0) result = read_fetch_snapshot_response(buffer) assert instance == result + + +@pytest.mark.java +@given(instance=from_type(FetchSnapshotResponse)) +def test_fetch_snapshot_response_java( + instance: FetchSnapshotResponse, java_tester: JavaTester +) -> None: + java_tester.test(instance) diff --git a/tests/generated/test_fetch_v0_response.py b/tests/generated/test_fetch_v0_response.py index d36a439f..10f2b77b 100644 --- a/tests/generated/test_fetch_v0_response.py +++ b/tests/generated/test_fetch_v0_response.py @@ -12,6 +12,7 @@ from kio.schema.fetch.v0.response import PartitionData from kio.serial import entity_reader from kio.serial import entity_writer +from tests.conftest import JavaTester from tests.conftest import setup_buffer read_partition_data: Final = entity_reader(PartitionData) @@ -54,3 +55,9 @@ def test_fetch_response_roundtrip(instance: FetchResponse) -> None: buffer.seek(0) result = read_fetch_response(buffer) assert instance == result + + +@pytest.mark.java +@given(instance=from_type(FetchResponse)) +def test_fetch_response_java(instance: FetchResponse, java_tester: JavaTester) -> None: + java_tester.test(instance) diff --git a/tests/generated/test_fetch_v10_response.py b/tests/generated/test_fetch_v10_response.py index fad00351..ccf50375 100644 --- a/tests/generated/test_fetch_v10_response.py +++ b/tests/generated/test_fetch_v10_response.py @@ -13,6 +13,7 @@ from kio.schema.fetch.v10.response import PartitionData from kio.serial import entity_reader from kio.serial import entity_writer +from tests.conftest import JavaTester from tests.conftest import setup_buffer read_aborted_transaction: Final = entity_reader(AbortedTransaction) @@ -69,3 +70,9 @@ def test_fetch_response_roundtrip(instance: FetchResponse) -> None: buffer.seek(0) result = read_fetch_response(buffer) assert instance == result + + +@pytest.mark.java +@given(instance=from_type(FetchResponse)) +def test_fetch_response_java(instance: FetchResponse, java_tester: JavaTester) -> None: + java_tester.test(instance) diff --git a/tests/generated/test_fetch_v11_response.py b/tests/generated/test_fetch_v11_response.py index 203fc321..088ab2aa 100644 --- a/tests/generated/test_fetch_v11_response.py +++ b/tests/generated/test_fetch_v11_response.py @@ -13,6 +13,7 @@ from kio.schema.fetch.v11.response import PartitionData from kio.serial import entity_reader from kio.serial import entity_writer +from tests.conftest import JavaTester from tests.conftest import setup_buffer read_aborted_transaction: Final = entity_reader(AbortedTransaction) @@ -69,3 +70,9 @@ def test_fetch_response_roundtrip(instance: FetchResponse) -> None: buffer.seek(0) result = read_fetch_response(buffer) assert instance == result + + +@pytest.mark.java +@given(instance=from_type(FetchResponse)) +def test_fetch_response_java(instance: FetchResponse, java_tester: JavaTester) -> None: + java_tester.test(instance) diff --git a/tests/generated/test_fetch_v12_response.py b/tests/generated/test_fetch_v12_response.py index 5d8f1d02..c64f789c 100644 --- a/tests/generated/test_fetch_v12_response.py +++ b/tests/generated/test_fetch_v12_response.py @@ -16,6 +16,7 @@ from kio.schema.fetch.v12.response import SnapshotId from kio.serial import entity_reader from kio.serial import entity_writer +from tests.conftest import JavaTester from tests.conftest import setup_buffer read_epoch_end_offset: Final = entity_reader(EpochEndOffset) @@ -114,3 +115,9 @@ def test_fetch_response_roundtrip(instance: FetchResponse) -> None: buffer.seek(0) result = read_fetch_response(buffer) assert instance == result + + +@pytest.mark.java +@given(instance=from_type(FetchResponse)) +def test_fetch_response_java(instance: FetchResponse, java_tester: JavaTester) -> None: + java_tester.test(instance) diff --git a/tests/generated/test_fetch_v13_response.py b/tests/generated/test_fetch_v13_response.py index df506a57..d6930453 100644 --- a/tests/generated/test_fetch_v13_response.py +++ b/tests/generated/test_fetch_v13_response.py @@ -16,6 +16,7 @@ from kio.schema.fetch.v13.response import SnapshotId from kio.serial import entity_reader from kio.serial import entity_writer +from tests.conftest import JavaTester from tests.conftest import setup_buffer read_epoch_end_offset: Final = entity_reader(EpochEndOffset) @@ -114,3 +115,9 @@ def test_fetch_response_roundtrip(instance: FetchResponse) -> None: buffer.seek(0) result = read_fetch_response(buffer) assert instance == result + + +@pytest.mark.java +@given(instance=from_type(FetchResponse)) +def test_fetch_response_java(instance: FetchResponse, java_tester: JavaTester) -> None: + java_tester.test(instance) diff --git a/tests/generated/test_fetch_v14_response.py b/tests/generated/test_fetch_v14_response.py index 55e9ddfd..98163da7 100644 --- a/tests/generated/test_fetch_v14_response.py +++ b/tests/generated/test_fetch_v14_response.py @@ -16,6 +16,7 @@ from kio.schema.fetch.v14.response import SnapshotId from kio.serial import entity_reader from kio.serial import entity_writer +from tests.conftest import JavaTester from tests.conftest import setup_buffer read_epoch_end_offset: Final = entity_reader(EpochEndOffset) @@ -114,3 +115,9 @@ def test_fetch_response_roundtrip(instance: FetchResponse) -> None: buffer.seek(0) result = read_fetch_response(buffer) assert instance == result + + +@pytest.mark.java +@given(instance=from_type(FetchResponse)) +def test_fetch_response_java(instance: FetchResponse, java_tester: JavaTester) -> None: + java_tester.test(instance) diff --git a/tests/generated/test_fetch_v15_response.py b/tests/generated/test_fetch_v15_response.py index a801ef45..c55f42de 100644 --- a/tests/generated/test_fetch_v15_response.py +++ b/tests/generated/test_fetch_v15_response.py @@ -16,6 +16,7 @@ from kio.schema.fetch.v15.response import SnapshotId from kio.serial import entity_reader from kio.serial import entity_writer +from tests.conftest import JavaTester from tests.conftest import setup_buffer read_epoch_end_offset: Final = entity_reader(EpochEndOffset) @@ -114,3 +115,9 @@ def test_fetch_response_roundtrip(instance: FetchResponse) -> None: buffer.seek(0) result = read_fetch_response(buffer) assert instance == result + + +@pytest.mark.java +@given(instance=from_type(FetchResponse)) +def test_fetch_response_java(instance: FetchResponse, java_tester: JavaTester) -> None: + java_tester.test(instance) diff --git a/tests/generated/test_fetch_v1_response.py b/tests/generated/test_fetch_v1_response.py index 72053f37..8f591b96 100644 --- a/tests/generated/test_fetch_v1_response.py +++ b/tests/generated/test_fetch_v1_response.py @@ -12,6 +12,7 @@ from kio.schema.fetch.v1.response import PartitionData from kio.serial import entity_reader from kio.serial import entity_writer +from tests.conftest import JavaTester from tests.conftest import setup_buffer read_partition_data: Final = entity_reader(PartitionData) @@ -54,3 +55,9 @@ def test_fetch_response_roundtrip(instance: FetchResponse) -> None: buffer.seek(0) result = read_fetch_response(buffer) assert instance == result + + +@pytest.mark.java +@given(instance=from_type(FetchResponse)) +def test_fetch_response_java(instance: FetchResponse, java_tester: JavaTester) -> None: + java_tester.test(instance) diff --git a/tests/generated/test_fetch_v2_response.py b/tests/generated/test_fetch_v2_response.py index c0f50faa..8c73572b 100644 --- a/tests/generated/test_fetch_v2_response.py +++ b/tests/generated/test_fetch_v2_response.py @@ -12,6 +12,7 @@ from kio.schema.fetch.v2.response import PartitionData from kio.serial import entity_reader from kio.serial import entity_writer +from tests.conftest import JavaTester from tests.conftest import setup_buffer read_partition_data: Final = entity_reader(PartitionData) @@ -54,3 +55,9 @@ def test_fetch_response_roundtrip(instance: FetchResponse) -> None: buffer.seek(0) result = read_fetch_response(buffer) assert instance == result + + +@pytest.mark.java +@given(instance=from_type(FetchResponse)) +def test_fetch_response_java(instance: FetchResponse, java_tester: JavaTester) -> None: + java_tester.test(instance) diff --git a/tests/generated/test_fetch_v3_response.py b/tests/generated/test_fetch_v3_response.py index 2baf3565..06c2939f 100644 --- a/tests/generated/test_fetch_v3_response.py +++ b/tests/generated/test_fetch_v3_response.py @@ -12,6 +12,7 @@ from kio.schema.fetch.v3.response import PartitionData from kio.serial import entity_reader from kio.serial import entity_writer +from tests.conftest import JavaTester from tests.conftest import setup_buffer read_partition_data: Final = entity_reader(PartitionData) @@ -54,3 +55,9 @@ def test_fetch_response_roundtrip(instance: FetchResponse) -> None: buffer.seek(0) result = read_fetch_response(buffer) assert instance == result + + +@pytest.mark.java +@given(instance=from_type(FetchResponse)) +def test_fetch_response_java(instance: FetchResponse, java_tester: JavaTester) -> None: + java_tester.test(instance) diff --git a/tests/generated/test_fetch_v4_response.py b/tests/generated/test_fetch_v4_response.py index c894b4fe..faf7a3bf 100644 --- a/tests/generated/test_fetch_v4_response.py +++ b/tests/generated/test_fetch_v4_response.py @@ -13,6 +13,7 @@ from kio.schema.fetch.v4.response import PartitionData from kio.serial import entity_reader from kio.serial import entity_writer +from tests.conftest import JavaTester from tests.conftest import setup_buffer read_aborted_transaction: Final = entity_reader(AbortedTransaction) @@ -69,3 +70,9 @@ def test_fetch_response_roundtrip(instance: FetchResponse) -> None: buffer.seek(0) result = read_fetch_response(buffer) assert instance == result + + +@pytest.mark.java +@given(instance=from_type(FetchResponse)) +def test_fetch_response_java(instance: FetchResponse, java_tester: JavaTester) -> None: + java_tester.test(instance) diff --git a/tests/generated/test_fetch_v5_response.py b/tests/generated/test_fetch_v5_response.py index bc3cc5b1..f56e19c8 100644 --- a/tests/generated/test_fetch_v5_response.py +++ b/tests/generated/test_fetch_v5_response.py @@ -13,6 +13,7 @@ from kio.schema.fetch.v5.response import PartitionData from kio.serial import entity_reader from kio.serial import entity_writer +from tests.conftest import JavaTester from tests.conftest import setup_buffer read_aborted_transaction: Final = entity_reader(AbortedTransaction) @@ -69,3 +70,9 @@ def test_fetch_response_roundtrip(instance: FetchResponse) -> None: buffer.seek(0) result = read_fetch_response(buffer) assert instance == result + + +@pytest.mark.java +@given(instance=from_type(FetchResponse)) +def test_fetch_response_java(instance: FetchResponse, java_tester: JavaTester) -> None: + java_tester.test(instance) diff --git a/tests/generated/test_fetch_v6_response.py b/tests/generated/test_fetch_v6_response.py index b902660e..8311f0a8 100644 --- a/tests/generated/test_fetch_v6_response.py +++ b/tests/generated/test_fetch_v6_response.py @@ -13,6 +13,7 @@ from kio.schema.fetch.v6.response import PartitionData from kio.serial import entity_reader from kio.serial import entity_writer +from tests.conftest import JavaTester from tests.conftest import setup_buffer read_aborted_transaction: Final = entity_reader(AbortedTransaction) @@ -69,3 +70,9 @@ def test_fetch_response_roundtrip(instance: FetchResponse) -> None: buffer.seek(0) result = read_fetch_response(buffer) assert instance == result + + +@pytest.mark.java +@given(instance=from_type(FetchResponse)) +def test_fetch_response_java(instance: FetchResponse, java_tester: JavaTester) -> None: + java_tester.test(instance) diff --git a/tests/generated/test_fetch_v7_response.py b/tests/generated/test_fetch_v7_response.py index a4d1fb8d..014cf37f 100644 --- a/tests/generated/test_fetch_v7_response.py +++ b/tests/generated/test_fetch_v7_response.py @@ -13,6 +13,7 @@ from kio.schema.fetch.v7.response import PartitionData from kio.serial import entity_reader from kio.serial import entity_writer +from tests.conftest import JavaTester from tests.conftest import setup_buffer read_aborted_transaction: Final = entity_reader(AbortedTransaction) @@ -69,3 +70,9 @@ def test_fetch_response_roundtrip(instance: FetchResponse) -> None: buffer.seek(0) result = read_fetch_response(buffer) assert instance == result + + +@pytest.mark.java +@given(instance=from_type(FetchResponse)) +def test_fetch_response_java(instance: FetchResponse, java_tester: JavaTester) -> None: + java_tester.test(instance) diff --git a/tests/generated/test_fetch_v8_response.py b/tests/generated/test_fetch_v8_response.py index 7a7df4e0..21415ba0 100644 --- a/tests/generated/test_fetch_v8_response.py +++ b/tests/generated/test_fetch_v8_response.py @@ -13,6 +13,7 @@ from kio.schema.fetch.v8.response import PartitionData from kio.serial import entity_reader from kio.serial import entity_writer +from tests.conftest import JavaTester from tests.conftest import setup_buffer read_aborted_transaction: Final = entity_reader(AbortedTransaction) @@ -69,3 +70,9 @@ def test_fetch_response_roundtrip(instance: FetchResponse) -> None: buffer.seek(0) result = read_fetch_response(buffer) assert instance == result + + +@pytest.mark.java +@given(instance=from_type(FetchResponse)) +def test_fetch_response_java(instance: FetchResponse, java_tester: JavaTester) -> None: + java_tester.test(instance) diff --git a/tests/generated/test_fetch_v9_response.py b/tests/generated/test_fetch_v9_response.py index 9805ac57..b054a87d 100644 --- a/tests/generated/test_fetch_v9_response.py +++ b/tests/generated/test_fetch_v9_response.py @@ -13,6 +13,7 @@ from kio.schema.fetch.v9.response import PartitionData from kio.serial import entity_reader from kio.serial import entity_writer +from tests.conftest import JavaTester from tests.conftest import setup_buffer read_aborted_transaction: Final = entity_reader(AbortedTransaction) @@ -69,3 +70,9 @@ def test_fetch_response_roundtrip(instance: FetchResponse) -> None: buffer.seek(0) result = read_fetch_response(buffer) assert instance == result + + +@pytest.mark.java +@given(instance=from_type(FetchResponse)) +def test_fetch_response_java(instance: FetchResponse, java_tester: JavaTester) -> None: + java_tester.test(instance) diff --git a/tests/generated/test_produce_v0_request.py b/tests/generated/test_produce_v0_request.py index 6bbffc61..b5c1a8fd 100644 --- a/tests/generated/test_produce_v0_request.py +++ b/tests/generated/test_produce_v0_request.py @@ -12,6 +12,7 @@ from kio.schema.produce.v0.request import TopicProduceData from kio.serial import entity_reader from kio.serial import entity_writer +from tests.conftest import JavaTester from tests.conftest import setup_buffer read_partition_produce_data: Final = entity_reader(PartitionProduceData) @@ -54,3 +55,11 @@ def test_produce_request_roundtrip(instance: ProduceRequest) -> None: buffer.seek(0) result = read_produce_request(buffer) assert instance == result + + +@pytest.mark.java +@given(instance=from_type(ProduceRequest)) +def test_produce_request_java( + instance: ProduceRequest, java_tester: JavaTester +) -> None: + java_tester.test(instance) diff --git a/tests/generated/test_produce_v1_request.py b/tests/generated/test_produce_v1_request.py index 523c76c1..ae9a09e5 100644 --- a/tests/generated/test_produce_v1_request.py +++ b/tests/generated/test_produce_v1_request.py @@ -12,6 +12,7 @@ from kio.schema.produce.v1.request import TopicProduceData from kio.serial import entity_reader from kio.serial import entity_writer +from tests.conftest import JavaTester from tests.conftest import setup_buffer read_partition_produce_data: Final = entity_reader(PartitionProduceData) @@ -54,3 +55,11 @@ def test_produce_request_roundtrip(instance: ProduceRequest) -> None: buffer.seek(0) result = read_produce_request(buffer) assert instance == result + + +@pytest.mark.java +@given(instance=from_type(ProduceRequest)) +def test_produce_request_java( + instance: ProduceRequest, java_tester: JavaTester +) -> None: + java_tester.test(instance) diff --git a/tests/generated/test_produce_v2_request.py b/tests/generated/test_produce_v2_request.py index b0109067..88c7721d 100644 --- a/tests/generated/test_produce_v2_request.py +++ b/tests/generated/test_produce_v2_request.py @@ -12,6 +12,7 @@ from kio.schema.produce.v2.request import TopicProduceData from kio.serial import entity_reader from kio.serial import entity_writer +from tests.conftest import JavaTester from tests.conftest import setup_buffer read_partition_produce_data: Final = entity_reader(PartitionProduceData) @@ -54,3 +55,11 @@ def test_produce_request_roundtrip(instance: ProduceRequest) -> None: buffer.seek(0) result = read_produce_request(buffer) assert instance == result + + +@pytest.mark.java +@given(instance=from_type(ProduceRequest)) +def test_produce_request_java( + instance: ProduceRequest, java_tester: JavaTester +) -> None: + java_tester.test(instance) diff --git a/tests/generated/test_produce_v3_request.py b/tests/generated/test_produce_v3_request.py index 1df9df4e..cc323c6c 100644 --- a/tests/generated/test_produce_v3_request.py +++ b/tests/generated/test_produce_v3_request.py @@ -12,6 +12,7 @@ from kio.schema.produce.v3.request import TopicProduceData from kio.serial import entity_reader from kio.serial import entity_writer +from tests.conftest import JavaTester from tests.conftest import setup_buffer read_partition_produce_data: Final = entity_reader(PartitionProduceData) @@ -54,3 +55,11 @@ def test_produce_request_roundtrip(instance: ProduceRequest) -> None: buffer.seek(0) result = read_produce_request(buffer) assert instance == result + + +@pytest.mark.java +@given(instance=from_type(ProduceRequest)) +def test_produce_request_java( + instance: ProduceRequest, java_tester: JavaTester +) -> None: + java_tester.test(instance) diff --git a/tests/generated/test_produce_v4_request.py b/tests/generated/test_produce_v4_request.py index ee390027..c880ceed 100644 --- a/tests/generated/test_produce_v4_request.py +++ b/tests/generated/test_produce_v4_request.py @@ -12,6 +12,7 @@ from kio.schema.produce.v4.request import TopicProduceData from kio.serial import entity_reader from kio.serial import entity_writer +from tests.conftest import JavaTester from tests.conftest import setup_buffer read_partition_produce_data: Final = entity_reader(PartitionProduceData) @@ -54,3 +55,11 @@ def test_produce_request_roundtrip(instance: ProduceRequest) -> None: buffer.seek(0) result = read_produce_request(buffer) assert instance == result + + +@pytest.mark.java +@given(instance=from_type(ProduceRequest)) +def test_produce_request_java( + instance: ProduceRequest, java_tester: JavaTester +) -> None: + java_tester.test(instance) diff --git a/tests/generated/test_produce_v5_request.py b/tests/generated/test_produce_v5_request.py index e4521fa0..97ea81b1 100644 --- a/tests/generated/test_produce_v5_request.py +++ b/tests/generated/test_produce_v5_request.py @@ -12,6 +12,7 @@ from kio.schema.produce.v5.request import TopicProduceData from kio.serial import entity_reader from kio.serial import entity_writer +from tests.conftest import JavaTester from tests.conftest import setup_buffer read_partition_produce_data: Final = entity_reader(PartitionProduceData) @@ -54,3 +55,11 @@ def test_produce_request_roundtrip(instance: ProduceRequest) -> None: buffer.seek(0) result = read_produce_request(buffer) assert instance == result + + +@pytest.mark.java +@given(instance=from_type(ProduceRequest)) +def test_produce_request_java( + instance: ProduceRequest, java_tester: JavaTester +) -> None: + java_tester.test(instance) diff --git a/tests/generated/test_produce_v6_request.py b/tests/generated/test_produce_v6_request.py index adae3684..e110873d 100644 --- a/tests/generated/test_produce_v6_request.py +++ b/tests/generated/test_produce_v6_request.py @@ -12,6 +12,7 @@ from kio.schema.produce.v6.request import TopicProduceData from kio.serial import entity_reader from kio.serial import entity_writer +from tests.conftest import JavaTester from tests.conftest import setup_buffer read_partition_produce_data: Final = entity_reader(PartitionProduceData) @@ -54,3 +55,11 @@ def test_produce_request_roundtrip(instance: ProduceRequest) -> None: buffer.seek(0) result = read_produce_request(buffer) assert instance == result + + +@pytest.mark.java +@given(instance=from_type(ProduceRequest)) +def test_produce_request_java( + instance: ProduceRequest, java_tester: JavaTester +) -> None: + java_tester.test(instance) diff --git a/tests/generated/test_produce_v7_request.py b/tests/generated/test_produce_v7_request.py index e1a5e1cf..0d087a2d 100644 --- a/tests/generated/test_produce_v7_request.py +++ b/tests/generated/test_produce_v7_request.py @@ -12,6 +12,7 @@ from kio.schema.produce.v7.request import TopicProduceData from kio.serial import entity_reader from kio.serial import entity_writer +from tests.conftest import JavaTester from tests.conftest import setup_buffer read_partition_produce_data: Final = entity_reader(PartitionProduceData) @@ -54,3 +55,11 @@ def test_produce_request_roundtrip(instance: ProduceRequest) -> None: buffer.seek(0) result = read_produce_request(buffer) assert instance == result + + +@pytest.mark.java +@given(instance=from_type(ProduceRequest)) +def test_produce_request_java( + instance: ProduceRequest, java_tester: JavaTester +) -> None: + java_tester.test(instance) diff --git a/tests/generated/test_produce_v8_request.py b/tests/generated/test_produce_v8_request.py index 0f536312..c3692f62 100644 --- a/tests/generated/test_produce_v8_request.py +++ b/tests/generated/test_produce_v8_request.py @@ -12,6 +12,7 @@ from kio.schema.produce.v8.request import TopicProduceData from kio.serial import entity_reader from kio.serial import entity_writer +from tests.conftest import JavaTester from tests.conftest import setup_buffer read_partition_produce_data: Final = entity_reader(PartitionProduceData) @@ -54,3 +55,11 @@ def test_produce_request_roundtrip(instance: ProduceRequest) -> None: buffer.seek(0) result = read_produce_request(buffer) assert instance == result + + +@pytest.mark.java +@given(instance=from_type(ProduceRequest)) +def test_produce_request_java( + instance: ProduceRequest, java_tester: JavaTester +) -> None: + java_tester.test(instance) diff --git a/tests/generated/test_produce_v9_request.py b/tests/generated/test_produce_v9_request.py index ea392ecd..20a0b224 100644 --- a/tests/generated/test_produce_v9_request.py +++ b/tests/generated/test_produce_v9_request.py @@ -12,6 +12,7 @@ from kio.schema.produce.v9.request import TopicProduceData from kio.serial import entity_reader from kio.serial import entity_writer +from tests.conftest import JavaTester from tests.conftest import setup_buffer read_partition_produce_data: Final = entity_reader(PartitionProduceData) @@ -54,3 +55,11 @@ def test_produce_request_roundtrip(instance: ProduceRequest) -> None: buffer.seek(0) result = read_produce_request(buffer) assert instance == result + + +@pytest.mark.java +@given(instance=from_type(ProduceRequest)) +def test_produce_request_java( + instance: ProduceRequest, java_tester: JavaTester +) -> None: + java_tester.test(instance)