Github-Mirror/seaweedfs
1
0 Fork 0
mirror of https://github.com/seaweedfs/seaweedfs.git synced 2026-10-10 08:17:44 +02:00
Code Issues Packages Projects Releases Wiki Activity
Files
fb97e3ea0695fa095140df2cd23eb3a2e459fb23
seaweedfs/weed/mq/kafka
T
History
chrislu ffc45a538d Added bounds checking after calculating startIdx. 
Problem: Race condition in cache lookup logic:
Thread A reads cache metadata (17+ records, endOffset = 32)
Thread B modifies/truncates the cache to 17 records
Thread A calculates startIdx = 19 based on old metadata
Slice operation consumedRecords[19:17] panics
2025-10-13 21:19:38 -07:00
..
compression
Add Kafka Gateway (#7231)
2025-10-13 18:05:17 -07:00
consumer
Add Kafka Gateway (#7231)
2025-10-13 18:05:17 -07:00
consumer_offset
Add Kafka Gateway (#7231)
2025-10-13 18:05:17 -07:00
gateway
Add Kafka Gateway (#7231)
2025-10-13 18:05:17 -07:00
integration
Added bounds checking after calculating startIdx.
2025-10-13 21:19:38 -07:00
protocol
Add Kafka Gateway (#7231)
2025-10-13 18:05:17 -07:00
schema
Add Kafka Gateway (#7231)
2025-10-13 18:05:17 -07:00
API_VERSION_MATRIX.md
Add Kafka Gateway (#7231)
2025-10-13 18:05:17 -07:00
package.go
Add Kafka Gateway (#7231)
2025-10-13 18:05:17 -07:00
partition_mapping_test.go
Add Kafka Gateway (#7231)
2025-10-13 18:05:17 -07:00
partition_mapping.go
Add Kafka Gateway (#7231)
2025-10-13 18:05:17 -07:00