Commit Graph

  • 33b79b3ef7
    Merge 1a98d7deb8 into 82fbf15b71 #7350 Chris Lu 2025-10-20 21:08:27 -0700
  • 1a98d7deb8 Fix deadlock in worker client Connect() method #7350 fix-worker-client-deadlock Chris Lu 2025-10-20 21:07:32 -0700
  • c5f04beae6
    Merge 1cb03cc7d2 into 82fbf15b71 #4898 ChengDaqi2023 2025-10-21 10:03:21 +0800
  • 994352fd32
    Merge 6afb215607 into 82fbf15b71 #7341 Mariano Ntrougkas 2025-10-20 18:55:51 -0700
  • 970ba4d824
    Merge 5ce9b8bd08 into 82fbf15b71 #7304 dependabot[bot] 2025-10-21 01:55:32 +0000
  • 82fbf15b71
    chore(deps): bump golang.org/x/image from 0.30.0 to 0.32.0 (#7343) master dependabot[bot] 2025-10-20 18:55:25 -0700
  • 2046b40414
    Merge 6d59a974eb into da18e3dc82 #7184 NyaMisty 2025-10-21 09:37:40 +0800
  • f4efb280c3
    Merge branch 'master' into dependabot/go_modules/golang.org/x/image-0.32.0 #7343 Chris Lu 2025-10-20 17:21:48 -0700
  • da18e3dc82
    chore(deps): bump golang.org/x/crypto from 0.42.0 to 0.43.0 (#7347) dependabot[bot] 2025-10-20 17:19:45 -0700
  • 2db8c54cc4
    Merge cfc7336aa9 into 5bec9e4114 #7340 nightcoffee 2025-10-20 17:12:41 -0700
  • 5bec9e4114
    chore(deps): bump github.com/klauspost/compress from 1.18.0 to 1.18.1 (#7344) dependabot[bot] 2025-10-20 17:01:29 -0700
  • 45e7eb1944
    Merge branch 'master' into dependabot/go_modules/golang.org/x/image-0.32.0 Chris Lu 2025-10-20 16:47:46 -0700
  • f30b6fa582
    Merge branch 'master' into dependabot/go_modules/golang.org/x/crypto-0.43.0 #7347 Chris Lu 2025-10-20 16:47:23 -0700
  • 1fa753abcb
    chore(deps): bump actions/setup-go from 5 to 6 (#7348) dependabot[bot] 2025-10-20 16:46:55 -0700
  • 6cc8cbfdfe go mod tidy chrislu 2025-10-20 16:24:25 -0700
  • 2b5ecaf693 go mod tidy #7344 chrislu 2025-10-20 16:24:12 -0700
  • 76d97e3f98 go mod tidy chrislu 2025-10-20 16:23:50 -0700
  • d073733834 go mod 2 chrislu 2025-10-20 16:23:32 -0700
  • db09c19caf go mod chrislu 2025-10-20 16:17:08 -0700
  • 783933c792 go mod chrislu 2025-10-20 16:16:25 -0700
  • 99abb95633 go mod chrislu 2025-10-20 16:14:59 -0700
  • c547cd7c18 fix tests chrislu 2025-10-20 16:13:41 -0700
  • ffd43218f6
    create new volumes on less occupied disk locations (#7349) Chris Lu 2025-10-20 16:11:29 -0700
  • dc383b522f
    chore(deps): bump actions/setup-go from 5 to 6 #7348 dependabot[bot] 2025-10-20 23:09:25 +0000
  • 3e8cc5a906
    chore(deps): bump github.com/redis/go-redis/v9 from 9.14.0 to 9.14.1 (#7342) dependabot[bot] 2025-10-20 16:03:43 -0700
  • 0baad7b5a1
    chore(deps): bump actions/checkout from 4 to 5 (#7345) dependabot[bot] 2025-10-20 16:03:24 -0700
  • f9861a3665 fixes #7349 chrislu 2025-10-20 15:54:09 -0700
  • 069e92b82e address comments chrislu 2025-10-20 15:46:56 -0700
  • 052cb8ac85 add unit tests chrislu 2025-10-20 15:32:14 -0700
  • 5401605a9f create new volumes on less occupied disk locations chrislu 2025-10-20 15:24:04 -0700
  • 9f13c583b8
    chore(deps): bump golang.org/x/crypto from 0.42.0 to 0.43.0 dependabot[bot] 2025-10-20 15:51:53 +0000
  • cc42eae8c7
    chore(deps): bump actions/checkout from 4 to 5 #7345 dependabot[bot] 2025-10-20 15:35:46 +0000
  • e8b8b98b86
    chore(deps): bump github.com/klauspost/compress from 1.18.0 to 1.18.1 dependabot[bot] 2025-10-20 15:30:40 +0000
  • 4750242275
    chore(deps): bump golang.org/x/image from 0.30.0 to 0.32.0 dependabot[bot] 2025-10-20 15:29:47 +0000
  • 5a899ed46a
    chore(deps): bump github.com/redis/go-redis/v9 from 9.14.0 to 9.14.1 #7342 dependabot[bot] 2025-10-20 15:29:15 +0000
  • 6afb215607
    Refactor connection locking to use read lock #7341 Mariano Ntrougkas 2025-10-20 16:06:17 +0300
  • 8953f19e3d
    Merge af6b029147 into 97f3028782 #3961 Adam Lamar 2025-10-20 16:01:17 +0800
  • cfc7336aa9
    Update master.toml #7340 nightcoffee 2025-10-20 01:42:07 +0800
  • 3d89b4d7eb
    Update master-cloud.toml nightcoffee 2025-10-20 01:40:58 +0800
  • 2a9b0026f0
    [weed] update volume.fix.replication description nightcoffee 2025-10-20 01:39:13 +0800
  • 9454e4ed0c
    Merge 53a70f4747 into 97f3028782 #6224 Guang Jiong Lou 2025-10-18 21:40:28 +0700
  • 35e03a62b5
    Merge d96b8b96e6 into 97f3028782 #7095 Konstantin Lebedev 2025-10-18 21:40:28 +0700
  • da7f6f5e78
    Merge edbb237e7a into 97f3028782 #7183 Chris Lu 2025-10-18 21:40:28 +0700
  • 55d734e9d1
    Merge b9ee15393f into 97f3028782 #7188 Bruce Zou 2025-10-18 21:40:28 +0700
  • b2ee9ec953
    Merge 7cfe6e20a5 into 97f3028782 #7236 Aleksey 2025-10-18 21:40:28 +0700
  • ee35390464
    Merge 6206a316f5 into 97f3028782 #7277 Taehyung Lim 2025-10-18 21:40:28 +0700
  • 9885591538
    Merge 65452abe1c into 97f3028782 #7312 Konstantin Lebedev 2025-10-18 21:40:28 +0700
  • 3fa2979fee
    Merge 4d519744cb into 97f3028782 #7271 littlemilkwu 2025-10-18 13:41:21 +0530
  • e0f856561a
    Merge ee078cea6c into 97f3028782 #7317 Nial 2025-10-18 13:45:36 +0800
  • 97f3028782
    Clean up logs and deprecated functions (#7339) Chris Lu 2025-10-17 22:11:50 -0700
  • 86e6d9e665 fix deprecated grpc.Dial #7339 chrislu 2025-10-17 21:24:41 -0700
  • b71d9e38a3 less logs chrislu 2025-10-17 21:22:52 -0700
  • 8d63a9cf5f
    Fixes for kafka gateway (#7329) Chris Lu 2025-10-17 20:49:47 -0700
  • f6ef486e1b adjust logs #7329 chrislu 2025-10-17 20:27:51 -0700
  • 9e11c4a8b9 fix join group chrislu 2025-10-17 19:41:09 -0700
  • 9ea2572966 fix response fmt chrislu 2025-10-17 19:18:25 -0700
  • d34feeb7e9 check for GroupStatePreparingRebalance chrislu 2025-10-17 18:43:26 -0700
  • 466aaa0ec3 Fix Kafka message corruption due to buffer sharing in produce requests chrislu 2025-10-17 18:01:45 -0700
  • c1e24f7116 Make a copy of recordSetData to prevent buffer sharing corruption chrislu 2025-10-17 18:01:45 -0700
  • 0019149ae2 Add comprehensive debug logging to diagnose message corruption in GitHub Actions chrislu 2025-10-17 17:54:29 -0700
  • ef658f3cd0 add debug chrislu 2025-10-17 17:37:24 -0700
  • 110f236a90 fix offset tracking in log buffer chrislu 2025-10-17 17:12:32 -0700
  • 3025b6abfc skip if If schema management is not enabled chrislu 2025-10-17 16:40:53 -0700
  • 2b8261c65b fix tests chrislu 2025-10-17 16:28:35 -0700
  • a8bc96e7e3 fix hostname chrislu 2025-10-17 16:10:34 -0700
  • 5425f647bc Validate that the unmarshaled RecordValue chrislu 2025-10-17 16:06:07 -0700
  • 0c27069cca Validate that the unmarshaled RecordValue has valid field data chrislu 2025-10-17 15:50:49 -0700
  • 23316d4d13 fix: Correct Kafka error codes - UNKNOWN_SERVER_ERROR = -1, OFFSET_OUT_OF_RANGE = 1 chrislu 2025-10-17 15:43:38 -0700
  • 50c16e0839 debug: Add verbose offset management logging chrislu 2025-10-17 15:34:27 -0700
  • a6cd014dad fix test chrislu 2025-10-17 15:33:20 -0700
  • ae94e4d8f1 fix: Check previous buffers even when offset < bufferStart chrislu 2025-10-17 15:14:30 -0700
  • 6af1dfcb61 fix: Invalidate disk cache after buffer flush to prevent stale data chrislu 2025-10-17 15:04:20 -0700
  • b1856dfc9f debug: Added detailed parseMessages logging to identify root cause chrislu 2025-10-17 15:01:58 -0700
  • b68b9c6dd6 test: Single-partition test confirms broker data retrieval bug chrislu 2025-10-17 14:53:58 -0700
  • dfd03396a1 test: Add production-scenario unit tests - buffer flush works correctly chrislu 2025-10-17 13:45:07 -0700
  • acc5f81104 Revert "fix: Add offset increment to AddDataToBuffer to prevent flush gaps" chrislu 2025-10-17 13:38:00 -0700
  • 2c28860aad fix: Add offset increment to AddDataToBuffer to prevent flush gaps chrislu 2025-10-17 13:10:10 -0700
  • f69e2a0c2d feat: Add unit tests to reproduce buffer flush offset gaps chrislu 2025-10-17 12:48:12 -0700
  • 0cdcb88081 feat: Identify root cause - data loss during buffer flush chrislu 2025-10-17 12:42:43 -0700
  • 4e98483661 feat: Add cache invalidation on extraction failure (incomplete fix) chrislu 2025-10-17 12:37:59 -0700
  • 2bc29f93d3 feat: Add comprehensive broker-side logging for disk read debugging chrislu 2025-10-17 12:30:01 -0700
  • be247ae497 feat: Add critical broker data retrieval bug detection logging chrislu 2025-10-17 12:07:48 -0700
  • f66960e445 feat: Add comprehensive server-side fetch request logging chrislu 2025-10-17 11:58:35 -0700
  • e9293cd201 debug: Add channel closure detection for early message stream termination chrislu 2025-10-17 11:20:02 -0700
  • 6ea2f8a4bd feat: Add comprehensive timeout and hang detection logging chrislu 2025-10-17 11:15:53 -0700
  • 006c8ac47c fix: Add topic auto-creation and cache invalidation to ALL metadata handlers chrislu 2025-10-17 10:52:45 -0700
  • 5d86a30d8e debug: Add comprehensive message flow logging - 73% improvement! chrislu 2025-10-17 10:18:19 -0700
  • e1addd3433 feat: Add HWM and Fetch logging - BREAKTHROUGH: Consumers now fetching messages! chrislu 2025-10-17 10:12:17 -0700
  • 476ea5758f feat: Add detailed logging for topic visibility debugging chrislu 2025-10-17 10:02:47 -0700
  • a5db489f82 fix: Add topic cache invalidation and auto-creation on metadata requests chrislu 2025-10-17 09:55:07 -0700
  • 3c1df04c9a test: Add consumer stalling reproducer tests chrislu 2025-10-17 09:41:07 -0700
  • 3c74ae2151 test: Add comprehensive unit tests for offset/fetch pattern chrislu 2025-10-17 07:42:11 -0700
  • 851fe6f69e feat: Add detailed logging for offset tracking and partition assignment chrislu 2025-10-17 00:42:03 -0700
  • 97be7c6aee simplify: Rely on in-memory commit as source of truth for offsets chrislu 2025-10-16 23:53:48 -0700
  • b3c3c38cb2 optimize: Make persistent offset storage writes asynchronous chrislu 2025-10-16 23:51:19 -0700
  • ec114b09b4 fix: Ensure atomic offset commits to prevent message loss and duplicates chrislu 2025-10-16 23:44:19 -0700
  • 133698a9c4 tune: Adjust commit frequency to every 20 messages for optimal balance chrislu 2025-10-16 23:36:48 -0700
  • ebdabdc8fe fix: Balance commit frequency at every 50 messages chrislu 2025-10-16 23:23:49 -0700
  • 5ae0b21b22 fix: Reduce manual commit frequency from every 10 to every 100 messages chrislu 2025-10-16 23:17:32 -0700
  • 690754acb7 fix: Increase fetch batch sizes to utilize available maxBytes capacity chrislu 2025-10-16 23:07:00 -0700