Commits

Branch selector

 trunk

User selector

guozhangwang

All time

Commit History

Commits on Oct 14, 2022

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

  Show description for 55a3a95
  guozhangwang

  authored
  55a3a95

  Copy full SHA for 55a3a95

• Kafka Streams Threading P2: Skeleton TaskExecutor Impl (#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 (#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 (#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 (#12519)

  Show description for 8380d2e
  guozhangwang

  authored
  8380d2e

  Copy full SHA for 8380d2e

Commits on Aug 25, 2022

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

  Show description for 63e6fdc
  guozhangwang

  authored
  63e6fdc

  Copy full SHA for 63e6fdc

Commits on Aug 19, 2022

• MINOR: Improve KafkaProducer Javadocs (#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 (#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 (#12476)

  Show description for 5ceaa58
  guozhangwang

  authored
  5ceaa58

  Copy full SHA for 5ceaa58

• KAFKA-13877: Fix flakiness in RackAwarenessIntegrationTest (#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 (#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 (#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 (#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 (#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 (#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 (#12363)

  Show description for ae570f5
  guozhangwang

  authored
  ae570f5

  Copy full SHA for ae570f5

Commits on Jun 29, 2022

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

  Show description for 3faa6cf
  guozhangwang

  authored
  3faa6cf

  Copy full SHA for 3faa6cf

• [9/N][Emit final] Emit final for session window aggregations (#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 (#12279)

  Show description for 925c628
  guozhangwang

  authored
  925c628

  Copy full SHA for 925c628

Commits on Jun 18, 2022

• KAFKA-13880: Remove DefaultPartitioner from StreamPartitioner (#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 (#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 (#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 (#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 (#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 (#12100)

  Show description for cc2aa96
  guozhangwang

  authored
  cc2aa96

  Copy full SHA for cc2aa96

Commits on Apr 27, 2022

• HOTFIX: Only measure in nano when producer metadata refresh is required (#12102)

  Show description for e026384
  guozhangwang

  authored
  e026384

  Copy full SHA for e026384

Commits on Mar 29, 2022

• MINOR: Fix log4j entry in RepartitionTopics (#11958)

  Show description for 19a6269
  guozhangwang

  authored
  19a6269

  Copy full SHA for 19a6269

Commits on Mar 15, 2022

• MINOR: Disable those flaky tests (#11895)

  Show description for cad4985
  guozhangwang

  authored
  cad4985

  Copy full SHA for cad4985

Commits on Mar 14, 2022

• KAFKA-13690: Fix flaky test in EosIntegrationTest (#11887)

  Show description for b916cb4
  guozhangwang

  authored
  b916cb4

  Copy full SHA for b916cb4

Commits on Jan 6, 2022

• MINOR: Add num threads logging upon shutdown (#11652)

  Show description for 9078451
  guozhangwang

  authored
  9078451

  Copy full SHA for 9078451

Commits on Oct 12, 2021

• KAFKA-13319: Do not commit empty offsets on producer (#11362)

  Show description for e31a53a
  guozhangwang

  authored
  e31a53a

  Copy full SHA for e31a53a

Commits on Sep 17, 2021

• MINOR: Let the list-store return null in putifabsent (#11335)

  Show description for 1b0294d
  guozhangwang

  authored
  1b0294d

  Copy full SHA for 1b0294d

Commits on Sep 16, 2021

• KAFKA-13216: Use a KV with list serde for the shared store (#11252)

  Show description for a0c7e6d
  guozhangwang

  authored
  a0c7e6d

  Copy full SHA for a0c7e6d

Pagination

Previous

Next