.. |
avro_decoder.go
|
ensure following kafka standard
|
2025-09-16 10:31:16 -07:00 |
avro_decoder_test.go
|
fix tests
|
2025-09-13 08:06:36 -07:00 |
broker_client.go
|
fix test errors
|
2025-09-13 00:17:54 -07:00 |
broker_client_fetch_test.go
|
fix tests
|
2025-09-13 08:06:36 -07:00 |
broker_client_test.go
|
fix tests
|
2025-09-16 23:41:48 -07:00 |
decode_encode_basic_test.go
|
add decode encode test
|
2025-09-11 14:05:04 -07:00 |
decode_encode_test.go
|
kafka: fix Avro union re-encoding issue
|
2025-09-15 22:31:29 -07:00 |
envelope.go
|
feat: implement Protobuf index varints handling
|
2025-09-15 22:56:32 -07:00 |
envelope_test.go
|
Phase 1: Add Confluent envelope parser for Kafka schema detection
|
2025-09-11 11:23:03 -07:00 |
envelope_varint_test.go
|
feat: implement Protobuf index varints handling
|
2025-09-15 22:56:32 -07:00 |
evolution.go
|
persist kafka offset
|
2025-09-11 19:53:00 -07:00 |
evolution_test.go
|
persist kafka offset
|
2025-09-11 19:53:00 -07:00 |
integration_test.go
|
fix: resolve Avro union re-encoding and schema validation test issues
|
2025-09-15 23:08:53 -07:00 |
json_schema_decoder.go
|
Phase 6: Add JSON Schema decoder support for Kafka Gateway
|
2025-09-11 12:18:40 -07:00 |
json_schema_decoder_test.go
|
Phase 6: Add JSON Schema decoder support for Kafka Gateway
|
2025-09-11 12:18:40 -07:00 |
manager.go
|
feat: implement per-topic schema validation in produce handler
|
2025-09-15 22:50:44 -07:00 |
manager_evolution_test.go
|
persist kafka offset
|
2025-09-11 19:53:00 -07:00 |
manager_test.go
|
fmt
|
2025-09-11 12:11:33 -07:00 |
protobuf_decoder.go
|
feat: implement Protobuf index varints handling
|
2025-09-15 22:56:32 -07:00 |
protobuf_decoder_test.go
|
persist kafka offset
|
2025-09-11 19:53:00 -07:00 |
protobuf_descriptor.go
|
kafka: implement Protobuf descriptor field APIs
|
2025-09-15 22:33:52 -07:00 |
protobuf_descriptor_test.go
|
kafka: implement Protobuf descriptor field APIs
|
2025-09-15 22:33:52 -07:00 |
reconstruction_test.go
|
fix tests
|
2025-09-13 08:06:36 -07:00 |
registry_client.go
|
fix tests
|
2025-09-13 08:06:36 -07:00 |
registry_client_test.go
|
Phase 2: Add Schema Registry HTTP client with caching
|
2025-09-11 11:25:09 -07:00 |