Github-Mirror/seaweedfs
1
0 Fork 0
mirror of https://github.com/seaweedfs/seaweedfs.git synced 2026-11-02 10:17:10 +01:00
Code Issues Packages Projects Releases Wiki Activity
Files
76ddaa8b842f365e1ec4d97c731876a00a479c4b
seaweedfs/weed/mq/kafka/protocol
T
History
chrislu 56ba8ce219 Phase 3: Add comprehensive integration tests 
- Add end-to-end flow tests for Kafka OffsetCommit to SMQ storage
- Test multiple consumer groups with independent offset tracking
- Validate SMQ file path and format compatibility
- Test error handling and edge cases (negative, zero, max offsets)
- Verify offset encoding/decoding matches SMQ broker format
- Ensure consumer group isolation and proper key generation
2025-09-12 21:00:30 -07:00
..
consumer_coordination_test.go
mq(kafka): Phase 3 Step 3 - Consumer Coordination
2025-09-10 13:50:30 -07:00
consumer_coordination.go
mq(kafka): Phase 3 Step 3 - Consumer Coordination
2025-09-10 13:50:30 -07:00
fetch_test.go
protocol: align request parsing with Kafka specs; remove client_id skips; revert OffsetFetch v0-v5 to classic encodings; adjust FindCoordinator parsing; update ApiVersions Metadata max v7; fix tests to pass apiVersion and expectations
2025-09-12 16:19:23 -07:00
fetch.go
kafka gateway: strip client_id in header; align handlers with spec; fix ApiVersions count; correct Metadata/ListOffsets v0 tests; robust Produce v2+ parsing (transactional_id fallback, acks=0 empty response, unknown topic errors); relax record set/test extraction; fix OffsetCommit/OffsetFetch parsing and tests; Fetch returns UNKNOWN_TOPIC_OR_PARTITION for missing topic
2025-09-12 17:11:54 -07:00
find_coordinator.go
tests(protocol): add/align spec-based tests; fix parsing to strip client_id at header level by removing client_id assumptions in JoinGroup/SyncGroup/OffsetFetch/FindCoordinator bodies; revert OffsetFetch to classic encodings for v0-v5
2025-09-12 16:05:56 -07:00
handler_test.go
tests: align ApiVersions test expectations with advertised ranges (ListOffsets v0-2, Fetch v0-7)
2025-09-12 17:43:57 -07:00
handler.go
Phase 3: Add comprehensive integration tests
2025-09-12 21:00:30 -07:00
joingroup.go
kafka gateway: add comprehensive version matrix tests for JoinGroup v0/v5, SyncGroup v0/v3, OffsetFetch v1/v2, FindCoordinator v0/v1/v2, ListOffsets v0/v1/v2; make parsers version-aware for RebalanceTimeout (v1+) and GroupInstanceID (v5+ for JoinGroup, v3+ for SyncGroup); ensure format correctness across API versions
2025-09-12 17:34:29 -07:00
offset_handlers_test.go
Phase 2: Wire OffsetCommit/OffsetFetch to SMQ storage
2025-09-12 20:58:43 -07:00
offset_management_test.go
kafka gateway: strip client_id in header; align handlers with spec; fix ApiVersions count; correct Metadata/ListOffsets v0 tests; robust Produce v2+ parsing (transactional_id fallback, acks=0 empty response, unknown topic errors); relax record set/test extraction; fix OffsetCommit/OffsetFetch parsing and tests; Fetch returns UNKNOWN_TOPIC_OR_PARTITION for missing topic
2025-09-12 17:11:54 -07:00
offset_management.go
Phase 3: Add comprehensive integration tests
2025-09-12 21:00:30 -07:00
produce_schema_test.go
kafka gateway: strip client_id in header; align handlers with spec; fix ApiVersions count; correct Metadata/ListOffsets v0 tests; robust Produce v2+ parsing (transactional_id fallback, acks=0 empty response, unknown topic errors); relax record set/test extraction; fix OffsetCommit/OffsetFetch parsing and tests; Fetch returns UNKNOWN_TOPIC_OR_PARTITION for missing topic
2025-09-12 17:11:54 -07:00
produce_test.go
protocol: align request parsing with Kafka specs; remove client_id skips; revert OffsetFetch v0-v5 to classic encodings; adjust FindCoordinator parsing; update ApiVersions Metadata max v7; fix tests to pass apiVersion and expectations
2025-09-12 16:19:23 -07:00
produce.go
kafka gateway: strip client_id in header; align handlers with spec; fix ApiVersions count; correct Metadata/ListOffsets v0 tests; robust Produce v2+ parsing (transactional_id fallback, acks=0 empty response, unknown topic errors); relax record set/test extraction; fix OffsetCommit/OffsetFetch parsing and tests; Fetch returns UNKNOWN_TOPIC_OR_PARTITION for missing topic
2025-09-12 17:11:54 -07:00
record_batch_parser_test.go
persist kafka offset
2025-09-11 19:53:00 -07:00
record_batch_parser.go
persist kafka offset
2025-09-11 19:53:00 -07:00
version_matrix_test.go
kafka gateway: add comprehensive version matrix tests for JoinGroup v0/v5, SyncGroup v0/v3, OffsetFetch v1/v2, FindCoordinator v0/v1/v2, ListOffsets v0/v1/v2; make parsers version-aware for RebalanceTimeout (v1+) and GroupInstanceID (v5+ for JoinGroup, v3+ for SyncGroup); ensure format correctness across API versions
2025-09-12 17:34:29 -07:00