Commits

Branch selector

 trunk

User selector

ableegoldman

Datepicker

All time

Commit History

Commits on Aug 6, 2021

• KAFKA-12648: Pt. 3 - addNamedTopology API (#10788)

  Show description for 6854eb8
  ableegoldman

  authored
  6854eb8

  Copy full SHA for 6854eb8

Commits on Jul 30, 2021

• KAFKA-12648: minor followup from Pt. 2 and some new tests (#11146)

  Show description for 5d52de2
  ableegoldman

  authored
  5d52de2

  Copy full SHA for 5d52de2

Commits on Jul 28, 2021

• KAFKA-12648: Pt. 2 - Introduce TopologyMetadata to wrap InternalTopologyBuilders of named topologies (#10683)

  Show description for 4710a49
  ableegoldman

  authored
  4710a49

  Copy full SHA for 4710a49

Commits on Jul 26, 2021

• MINOR: factor state checks into descriptive methods and clarify javadocs (#11123)

  Show description for 246a8af
  ableegoldman

  authored
  246a8af

  Copy full SHA for 246a8af

Commits on Jul 23, 2021

• KAFKA-13126: guard against overflow when computing `joinGroupTimeoutMs` (#11111)

  Show description for 8b1eca1
  ableegoldman

  authored
  8b1eca1

  Copy full SHA for 8b1eca1

• KAFKA-13021: clarify KIP-633 javadocs and address remaining feedback (#11114)

  Show description for 7fbc6b7
  ableegoldman

  authored
  7fbc6b7

  Copy full SHA for 7fbc6b7

• KAFKA-13128: wait for all keys to be fully processed in #shouldQueryStoresAfterAddingAndRemovingStreamThread (#11113)

  Show description for 03edcdd
  ableegoldman

  authored
  03edcdd

  Copy full SHA for 03edcdd

Commits on Jul 22, 2021

• HOTFIX: Set session interval back to 10s for StreamsCooperativeRebalanceUpgradeTest (#11103)

  Show description for d99562a
  ableegoldman

  authored
  d99562a

  Copy full SHA for d99562a

Commits on Jul 14, 2021

• KAFKA-12984: make AbstractStickyAssignor resilient to invalid input, utilize generation in cooperative, and fix assignment bug (#10985)

  Show description for 37d086f
  ableegoldman

  authored
  37d086f

  Copy full SHA for 37d086f

Commits on Jul 13, 2021

• KAFKA-12983: reset needsJoinPrepare flag before rejoining the group (#10986)

  Show description for 1f64df9
  ableegoldman

  authored
  1f64df9

  Copy full SHA for 1f64df9

Commits on Jul 8, 2021

• MINOR: fix typo in config for eos-v2 docs of the upgrade guide (#11001)

  Show description for 53f9b04
  ableegoldman

  authored
  53f9b04

  Copy full SHA for 53f9b04

• MINOR: StreamsPartitionAssignor should log the individual members of each client (#10996)

  Show description for 66e8b8b
  ableegoldman

  authored
  66e8b8b

  Copy full SHA for 66e8b8b

Commits on Jun 7, 2021

• KAFKA-12648: Pt. 1 - Add NamedTopology to protocol and state directory structure (#10609)

  Show description for 48379bd
  ableegoldman

  authored
  48379bd

  Copy full SHA for 48379bd

Commits on May 26, 2021

• MINOR: deprecate TaskMetadata constructor and add KIP-740 notes to upgrade guide (#10755)

  Show description for bbe170a
  ableegoldman

  authored
  bbe170a

  Copy full SHA for bbe170a

Commits on May 24, 2021

• MINOR: clarify message ordering with max in-flight requests and idempotent producer (#10690)

  Show description for 33df5c6
  ableegoldman

  authored
  33df5c6

  Copy full SHA for 33df5c6

Commits on May 20, 2021

• KAFKA-12779: KIP-740, Clean up public API in TaskId and fix TaskMetadata#taskId() (#10735)

  Show description for b56d9e4
  ableegoldman

  authored
  b56d9e4

  Copy full SHA for b56d9e4

Commits on May 18, 2021

• HOTFIX: undo renaming of public part of Subtopology API (#10713)

  Show description for 3a42baa
  ableegoldman

  authored
  3a42baa

  Copy full SHA for 3a42baa

Commits on May 17, 2021

• KAFKA-12574: remove internal Producer config and auto downgrade logic (#10675)

  Show description for cc6f4c4
  ableegoldman

  authored
  cc6f4c4

  Copy full SHA for cc6f4c4

Commits on May 13, 2021

• MINOR: prevent cleanup() from being called while Streams is still shutting down (#10666)

  Show description for 4153e75
  ableegoldman

  authored
  4153e75

  Copy full SHA for 4153e75

• KAFKA-12648: MINOR - Add TopologyMetadata.Subtopology class for subtopology metadata (#10676)

  Show description for 4b27365
  ableegoldman

  authored
  4b27365

  Copy full SHA for 4b27365

Commits on May 1, 2021

• KAFKA-12648: basic skeleton API for NamedTopology (#10615)

  Show description for 16b2ce7
  ableegoldman

  authored
  16b2ce7

  Copy full SHA for 16b2ce7

Commits on Apr 29, 2021

• MINOR: clean up some remaining locking stuff in StateDirectory (#10608)

  Show description for 9dbf222
  ableegoldman

  authored
  9dbf222

  Copy full SHA for 9dbf222

Commits on Apr 28, 2021

• KAFKA-12574: KIP-732, Deprecate eos-alpha and replace eos-beta with eos-v2 (#10573)

  Show description for 3805f37
  ableegoldman

  authored
  3805f37

  Copy full SHA for 3805f37

Commits on Apr 21, 2021

• MINOR: Bump latest 2.6 version to 2.6.2 (#10582)

  Show description for 3bfc9fe
  ableegoldman

  authored
  3bfc9fe

  Copy full SHA for 3bfc9fe

• HOTFIX: remove unimplemented SPILL_TO_DISK buffer full strategy (#10571)

  Show description for a24e78b
  ableegoldman

  authored
  a24e78b

  Copy full SHA for a24e78b

Commits on Apr 13, 2021

• KAFKA-7606: Remove deprecated options from StreamsResetter (#10411)

  Show description for c608d84
  ableegoldman

  authored
  c608d84

  Copy full SHA for c608d84

Commits on Apr 8, 2021

• MINOR: un-deprecate StreamsConfig overloads to support dependency injection (#10484)

  Show description for e9c5a39
  ableegoldman

  authored
  e9c5a39

  Copy full SHA for e9c5a39

Commits on Mar 31, 2021

• HOTFIX: move rebalanceInProgress check to skip commit during handleCorrupted (#10444)

  Show description for 3eff8d3
  ableegoldman

  authored
  3eff8d3

  Copy full SHA for 3eff8d3

• KAFKA-12288: remove task-level filesystem locks (#10342)

  Show description for 0189298
  ableegoldman

  authored
  0189298

  Copy full SHA for 0189298

Commits on Mar 29, 2021

• KAFKA-12523: handle TaskCorruption and TimeoutException during handleCorruption and handleRevocation (#10407)

  Show description for fb2eef9
  ableegoldman

  authored
  fb2eef9

  Copy full SHA for fb2eef9

Commits on Mar 20, 2021

• KAFKA-12500: fix memory leak in thread cache (#10355)

  Show description for 13b4ca8
  ableegoldman

  authored
  13b4ca8

  Copy full SHA for 13b4ca8

Commits on Mar 13, 2021

• KAFKA-12462: proceed with task revocation in case of thread in PENDING_SHUTDOWN (#10311)

  Show description for 4fe4cdc
  ableegoldman

  authored
  4fe4cdc

  Copy full SHA for 4fe4cdc

Commits on Mar 4, 2021

• MINOR: add missing docs for record-e2e-latency metrics (#10251)

  Show description for 5c22e03
  ableegoldman

  authored
  5c22e03

  Copy full SHA for 5c22e03

Commits on Mar 3, 2021

• KAFKA-12375: don't reuse thread.id until a thread has fully shut down (#10215)

  Show description for 23b61ba
  ableegoldman

  authored
  23b61ba

  Copy full SHA for 23b61ba

Commits on Feb 23, 2021

• MINOR: document restriction against running multiple Streams apps on same state.dir (#10187)

  Show description for 0605b69
  ableegoldman

  authored
  0605b69

  Copy full SHA for 0605b69

Pagination

Previous

Next