Commits

Branch selector

 trunk

User selector

guozhangwang

Datepicker

All time

Commit History

Commits on Apr 12, 2023

• MINOR: Follow-up on failing streams test, and fix StoreChangelogReader (apache#13523)

  Show description for 750a389
  guozhangwang

  authored
  750a389

  Copy full SHA for 750a389

Commits on Apr 5, 2023

• KAFKA-14172: Should clear cache when active recycled from standby (apache#13369)

  Show description for b2ee6df
  guozhangwang

  authored
  b2ee6df

  Copy full SHA for b2ee6df

• KAFKA-10199: Add task updater metrics, part 2 (apache#13300)

  Show description for 653baa6
  guozhangwang

  authored
  653baa6

  Copy full SHA for 653baa6

Commits on Apr 4, 2023

• KAFKA-14533: Do not interrupt state-updater thread during shutdown (apache#13318)

  Show description for beb0be5
  guozhangwang

  authored
  beb0be5

  Copy full SHA for beb0be5

Commits on Mar 2, 2023

• MINOR: Fix flaky tests in DefaultStateUpdaterTest (apache#13319)

  Show description for 5842953
  guozhangwang

  authored
  5842953

  Copy full SHA for 5842953

Commits on Feb 24, 2023

• KAFKA-10199: Add task updater metrics, part 1 (apache#13228)

  Show description for 2fad165
  guozhangwang

  authored
  2fad165

  Copy full SHA for 2fad165

Commits on Feb 9, 2023

• KAFKA-14650: Synchronize access to tasks inside task manager (apache#13167)

  Show description for 083e11a
  guozhangwang

  authored
  083e11a

  Copy full SHA for 083e11a

Commits on Feb 7, 2023

• KAFKA-10575: Add onRestoreSuspsnded to StateRestoreListener (apache#13179)

  Show description for 788793d
  guozhangwang

  authored
  788793d

  Copy full SHA for 788793d

Commits on Oct 14, 2022

• Kafka Streams Threading P3: TaskManager Impl (apache#12754)

  Show description for 55a3a95
  guozhangwang

  authored
  55a3a95

  Copy full SHA for 55a3a95

• Kafka Streams Threading P2: Skeleton TaskExecutor Impl (apache#12744)

  Show description for dfb5929
  guozhangwang

  authored
  dfb5929

  Copy full SHA for dfb5929

Commits on Oct 12, 2022

• Kafka Streams Threading P1: Add Interface for new TaskManager and TaskExecutor (apache#12737)

  Show description for 69059b5
  guozhangwang

  authored
  69059b5

  Copy full SHA for 69059b5

Commits on Sep 28, 2022

• KAFKA-10199: Integrate Topology Pause/Resume with StateUpdater (apache#12659)

  Show description for d62a42d
  guozhangwang

  authored
  d62a42d

  Copy full SHA for d62a42d

Commits on Sep 3, 2022

• KAFKA-10199: Handle exceptions from state updater (apache#12519)

  Show description for 8380d2e
  guozhangwang

  authored
  8380d2e

  Copy full SHA for 8380d2e

Commits on Aug 25, 2022

• MINOR: Improve javadocs for offset retention (apache#12552)

  Show description for 63e6fdc
  guozhangwang

  authored
  63e6fdc

  Copy full SHA for 63e6fdc

Commits on Aug 19, 2022

• MINOR: Improve KafkaProducer Javadocs (apache#12537)

  Show description for 5d32f24
  guozhangwang

  authored
  5d32f24

  Copy full SHA for 5d32f24

Commits on Aug 16, 2022

• KAFKA-10199: Handle task closure and recycling from state updater (apache#12466)

  Show description for dc72f6e
  guozhangwang

  authored
  dc72f6e

  Copy full SHA for dc72f6e

Commits on Aug 3, 2022

• HOTFIX / KAFKA-14130: Reduce RackAwarenesssTest to unit Test (apache#12476)

  Show description for 5ceaa58
  guozhangwang

  authored
  5ceaa58

  Copy full SHA for 5ceaa58

• KAFKA-13877: Fix flakiness in RackAwarenessIntegrationTest (apache#12468)

  Show description for 3202459
  guozhangwang

  authored
  3202459

  Copy full SHA for 3202459

Commits on Jul 28, 2022

• KAFKA-10199: Further refactor task lifecycle management (apache#12439)

  Show description for 06f47c3
  guozhangwang

  authored
  06f47c3

  Copy full SHA for 06f47c3

Commits on Jul 21, 2022

• KAFKA-10199: Cleanup TaskManager and Task interfaces (apache#12397)

  Show description for c9b6e19
  guozhangwang

  authored
  c9b6e19

  Copy full SHA for c9b6e19

Commits on Jul 19, 2022

• KAFKA-10199: Add RESUME in state updater (apache#12387)

  Show description for 693e283
  guozhangwang

  authored
  693e283

  Copy full SHA for 693e283

Commits on Jul 18, 2022

• KAFKA-10199: Add PAUSE in state updater (apache#12386)

  Show description for 309e0f9
  guozhangwang

  authored
  309e0f9

  Copy full SHA for 309e0f9

Commits on Jul 7, 2022

• HOTFIX: KIP-851, rename requireStable in ListConsumerGroupOffsetsOptions

  guozhangwang

  committed
  ca8135b

  Copy full SHA for ca8135b

• KAFKA-10199: Remove main consumer from store changelog reader (apache#12337)

  Show description for 915c781
  guozhangwang

  authored
  915c781

  Copy full SHA for 915c781

Commits on Jul 3, 2022

• HOTFIX: Correct ordering of input buffer and enforced processing sensors (apache#12363)

  Show description for ae570f5
  guozhangwang

  authored
  ae570f5

  Copy full SHA for ae570f5

Commits on Jun 29, 2022

• MINOR: Use mock time in DefaultStateUpdaterTest (apache#12344)

  Show description for 3faa6cf
  guozhangwang

  authored
  3faa6cf

  Copy full SHA for 3faa6cf

• [9/N][Emit final] Emit final for session window aggregations (apache#12204)

  Show description for ababc42
  guozhangwang

  authored
  ababc42

  Copy full SHA for ababc42

Commits on Jun 23, 2022

• KAFKA-10199: Commit the restoration progress within StateUpdater (apache#12279)

  Show description for 925c628
  guozhangwang

  authored
  925c628

  Copy full SHA for 925c628

Commits on Jun 18, 2022

• KAFKA-13880: Remove DefaultPartitioner from StreamPartitioner (apache#12304)

  Show description for cfdd567
  guozhangwang

  authored
  cfdd567

  Copy full SHA for cfdd567

Commits on Jun 14, 2022

• KAFKA-13846: Use the new addMetricsIfAbsent API (apache#12287)

  Show description for 39a555b
  guozhangwang

  authored
  39a555b

  Copy full SHA for 39a555b

Commits on Jun 6, 2022

• HOTFIX: add space to avoid checkstyle failure

  guozhangwang

  committed
  5d59328

  Copy full SHA for 5d59328

• HOTFIX: only try to clear discover-coordinator future upon commit (apache#12244)

  Show description for 2047fc3
  guozhangwang

  authored
  2047fc3

  Copy full SHA for 2047fc3

Commits on May 14, 2022

• KAFKA-13785: [7/N][Emit final] emit final for sliding window (apache#12135)

  Show description for 46efb72
  guozhangwang

  authored
  46efb72

  Copy full SHA for 46efb72

Commits on May 5, 2022

• KAFKA-13785: [8/N][emit final] time-ordered session store (apache#12127)

  Show description for 3b08dea
  guozhangwang

  authored
  3b08dea

  Copy full SHA for 3b08dea

Commits on May 3, 2022

• KAFKA-13785: [6/N][Emit final] Copy: Emit final for TimeWindowedKStreamImpl (apache#12100)

  Show description for cc2aa96
  guozhangwang

  authored
  cc2aa96

  Copy full SHA for cc2aa96

Pagination

Previous

Next