Github-Mirror/seaweedfs
1
0
Fork 0
mirror of https://github.com/seaweedfs/seaweedfs.git synced 2026-09-13 10:00:41 +02:00
Code Issues Packages Projects Releases Wiki Activity
12,095 Commits 176 Branches 359 Tags
cee8fa3f99f99a672f71eba1b7a01c0ec7ec4653
Commit Graph
12095 Commits
This Branch
This Branch
All Branches
Author SHA1 Message Date
chrislu cee8fa3f99 randomize 2025-09-14 14:53:23 -07:00
chrislu 40ecd6ad6e Update s3tests.yml 2025-09-14 14:45:41 -07:00
chrislu 033237a732 fix path for -s3.config=../docker/compose/s3.json 2025-09-14 14:36:00 -07:00
chrislu ec7adc5a36 Update fetch_multibatch.go 2025-09-14 14:10:44 -07:00
chrislu d0059cb65b update plans 2025-09-14 13:36:20 -07:00
chrislu ef6a1f3798 Delete size.txt 2025-09-14 13:11:38 -07:00
chrislu 61bfe73029 Revert "Merge branch 'master' into feature/mq-kafka-gateway-m1" 
This reverts commit 78382b380e, reversing
changes made to 56aa5278af.
 2025-09-14 12:50:19 -07:00
chrislu 7c82d5e7a0 Update metadata_version_test.go 2025-09-14 12:05:11 -07:00
chrislu 75847eacfb update 2025-09-14 11:41:22 -07:00
chrislu 515a03a377 Update kafka-tests.yml 2025-09-14 11:29:30 -07:00
chrislu 6faa0e86a7 fux ulimit 2025-09-14 11:26:27 -07:00
chrislu 76a5cfbf1f fixes 2025-09-14 11:21:53 -07:00
chrislu 0437957db5 Update offset_management.go 2025-09-14 11:15:33 -07:00
chrislu 4e11a378fd fix tests 2025-09-14 10:52:23 -07:00
chrislu 881a418b95 Update kafka-tests.yml 2025-09-14 10:14:01 -07:00
chrislu 12d890d45c only run one test 2025-09-14 09:04:54 -07:00
chrislu 3b551fcaf7 Update kafka-tests.yml 2025-09-13 21:50:49 -07:00
chrislu 579de7381d Update kafka-tests.yml 2025-09-13 21:44:13 -07:00
chrislu 8b1962bd3a Update kafka-tests.yml 2025-09-13 21:43:55 -07:00
chrislu 8ff78983e3 separate containers 2025-09-13 21:41:32 -07:00
chrislu 3224e71e87 Update kafka-tests.yml 2025-09-13 21:32:15 -07:00
chrislu 58eb40db01 ctx.Done() 2025-09-13 21:29:27 -07:00
chrislu e501abcde6 timeout 2025-09-13 21:24:32 -07:00
chrislu 4a2642e54d more timeout 2025-09-13 21:20:54 -07:00
chrislu 1c21527179 timout 2025-09-13 21:15:05 -07:00
chrislu 5d5c820c88 timeouts 2025-09-13 21:07:24 -07:00
chrislu 75ffd30a03 goroutine-based context-cancellable I/O + aggressive goroutine timeouts 2025-09-13 20:58:51 -07:00
chrislu 48803d9a68 server shutdown timeout 2025-09-13 20:53:29 -07:00
chrislu 031c67dd5d Both io.ReadFull and time.Sleep are now context-aware 2025-09-13 20:45:34 -07:00
chrislu 015f6f2910 cancel ctx 2025-09-13 20:30:31 -07:00
chrislu 5a2fd1413f context-cancellable read 2025-09-13 20:23:58 -07:00
chrislu 18840d3f65 debug with 5 seconds timeout 2025-09-13 20:18:34 -07:00
chrislu b0ae15eac7 debug 2025-09-13 20:12:30 -07:00
chrislu f830917462 Update Dockerfile.kafka-gateway 2025-09-13 20:10:08 -07:00
chrislu 1904ba93a8 update 2025-09-13 20:07:08 -07:00
chrislu 5895f22d69 context is cancelled, the server will detect it immediately and exit gracefully 2025-09-13 20:02:11 -07:00
chrislu ac943d0a59 debug 2025-09-13 19:54:37 -07:00
chrislu ddbbbaa1dd debug 2025-09-13 19:41:55 -07:00
chrislu cf584a35ef Update server.go 2025-09-13 19:40:17 -07:00
chrislu f5871524be add debug messages 2025-09-13 19:04:17 -07:00
chrislu 8e69446112 fix tests 2025-09-13 18:49:04 -07:00
chrislu 368f526b9f fix Incorrect flexible version mapping 2025-09-13 18:36:39 -07:00
chrislu 93c3e0c784 fix tests 2025-09-13 18:27:35 -07:00
chrislu 2f040a0fe4 fix undefined method errors 2025-09-13 17:34:06 -07:00
chrislu d7e1c83ca8 Update Produce v2+ to store all records from batch to SMQ 
Update Produce v2+ to store all records from batch to SMQ
 2025-09-13 17:30:05 -07:00
chrislu a8bee174f4 Update fetch.go 
Skip long-polling if any requested topic does not exist.
Only long-poll when MinBytes > 0, data isn’t available yet, and all topics exist.
Cap the long-polling wait to 1s in tests to prevent hanging on shutdown.
 2025-09-13 17:14:51 -07:00
chrislu 9a4ad5047b Update handler.go 
Busy fetch loop: Implemented basic long-polling in Fetch. If no data and min_bytes>0 with max_wait_ms>0, we wait up to max_wait_ms, and populate throttle_time_ms accordingly. This stops the rapid loop for kafka-go on empty partitions.
 2025-09-13 16:55:56 -07:00
chrislu bbc8668fd6 Fix kafka-go client infinite polling loop 2025-09-13 16:39:55 -07:00
chrislu 78629d69c5 Delete IMPLEMENTATION_PHASES.md 2025-09-13 15:40:48 -07:00
chrislu 287c323fb6 Update IMPLEMENTATION_PHASES.md 2025-09-13 15:40:08 -07:00