| .. |
|
api_versions_test.go
|
Fix API version tests after adding DescribeGroups and ListGroups APIs
|
2025-09-15 21:03:05 -07:00 |
|
compression_test.go
|
Phase 1 Part 1: Multi-batch fetch and GZIP compression
|
2025-09-15 20:32:01 -07:00 |
|
consumer_coordination.go
|
kafka: fix deadlock issues in static membership tests
|
2025-09-15 21:42:32 -07:00 |
|
consumer_coordination_test.go
|
fix-leavegroup-api-versions
|
2025-09-15 12:07:04 -07:00 |
|
consumer_group_metadata.go
|
fix: Handle null user data in JoinGroup protocol metadata parsing
|
2025-09-15 10:46:59 -07:00 |
|
consumer_group_metadata_test.go
|
Phase 4: Implement consumer group protocol metadata parsing
|
2025-09-13 14:01:28 -07:00 |
|
create_topics_test.go
|
Phase 2: Implement CreateTopics protocol compliance for v0/v1
|
2025-09-13 13:18:54 -07:00 |
|
describe_configs_test.go
|
fix: implement correct DescribeConfigs response format for all API versions
|
2025-09-16 01:22:16 -07:00 |
|
error_handling_test.go
|
kafka: fix flaky TestTimeoutDetection test
|
2025-09-15 22:07:05 -07:00 |
|
errors.go
|
kafka: fix HandleTimeoutError to properly handle context timeout errors
|
2025-09-15 08:40:32 -07:00 |
|
fetch.go
|
address some TODOs
|
2025-09-16 12:21:05 -07:00 |
|
fetch_multibatch.go
|
Phase 1 Part 1: Multi-batch fetch and GZIP compression
|
2025-09-15 20:32:01 -07:00 |
|
fetch_multibatch_test.go
|
Phase 1 Part 1: Multi-batch fetch and GZIP compression
|
2025-09-15 20:32:01 -07:00 |
|
fetch_test.go
|
fix tests
|
2025-09-14 10:52:23 -07:00 |
|
find_coordinator.go
|
gateway serves as the essential protocol bridge between Kafka clients and SeaweedMQ storage, not just a discovery service
|
2025-09-16 23:35:50 -07:00 |
|
find_coordinator_test.go
|
fix tests
|
2025-09-17 00:47:28 -07:00 |
|
flexible_versions.go
|
fix tests
|
2025-09-13 18:49:04 -07:00 |
|
flexible_versions_integration_test.go
|
Fix API version tests after adding DescribeGroups and ListGroups APIs
|
2025-09-15 21:03:05 -07:00 |
|
flexible_versions_test.go
|
Phase 7: Comprehensive error handling and edge cases
|
2025-09-13 15:30:34 -07:00 |
|
group_introspection.go
|
Implement static membership support (group.instance.id)
|
2025-09-15 21:10:43 -07:00 |
|
group_introspection_test.go
|
Phase 1 Part 2: Group introspection APIs
|
2025-09-15 20:36:04 -07:00 |
|
handler.go
|
set clientHost
|
2025-09-18 00:43:29 -07:00 |
|
handler_test.go
|
fix tests
|
2025-09-17 00:12:56 -07:00 |
|
joingroup.go
|
kafka: fix deadlock issues in static membership tests
|
2025-09-15 21:42:32 -07:00 |
|
logging.go
|
Phase 0 Part 2: API cleanup and structured logging
|
2025-09-15 20:28:08 -07:00 |
|
metrics.go
|
Phase 1 Complete: Client compatibility and metrics
|
2025-09-15 20:45:06 -07:00 |
|
metrics_test.go
|
Phase 1 Complete: Client compatibility and metrics
|
2025-09-15 20:45:06 -07:00 |
|
offset_handlers_test.go
|
fix in-memory variables
|
2025-09-12 23:50:07 -07:00 |
|
offset_management.go
|
Phase 0 Part 1: Implement basic tests and offset fixes
|
2025-09-15 20:26:24 -07:00 |
|
offset_management_test.go
|
refactoring
|
2025-09-13 13:03:51 -07:00 |
|
produce.go
|
feat: implement per-topic schema validation in produce handler
|
2025-09-15 22:50:44 -07:00 |
|
produce_schema_test.go
|
fix tests
|
2025-09-13 08:06:36 -07:00 |
|
produce_schema_validation_test.go
|
fix: resolve Avro union re-encoding and schema validation test issues
|
2025-09-15 23:08:53 -07:00 |
|
produce_test.go
|
fix tests
|
2025-09-13 08:06:36 -07:00 |
|
record_batch_parser.go
|
persist kafka offset
|
2025-09-11 19:53:00 -07:00 |
|
record_batch_parser_test.go
|
persist kafka offset
|
2025-09-11 19:53:00 -07:00 |
|
schematized_fetch_integration_test.go
|
feat: integrate schematized fetch results into Fetch response
|
2025-09-16 00:29:39 -07:00 |
|
static_membership_test.go
|
Implement static membership support (group.instance.id)
|
2025-09-15 21:10:43 -07:00 |
|
test_handler.go
|
add tests
|
2025-09-17 00:58:14 -07:00 |
|
test_utils.go
|
fix tests
|
2025-09-17 00:12:56 -07:00 |
|
version_matrix_test.go
|
fix tests
|
2025-09-13 08:06:36 -07:00 |
|
zigzag_varint_test.go
|
fix: correct ZigZag varint encoding for Kafka record format v2
|
2025-09-16 00:25:33 -07:00 |
