Commits

Breadcrumbs

History for

ontrunk

User selector

All users

Datepicker

All time

Commit History

Commits on Jul 10, 2023

• KAFKA-15022: [1/N] initial implementation of rack aware assignor (apache#13851)

  Show description for 0e56cc8
  lihaosky

  authored
  0e56cc8

  Copy full SHA for 0e56cc8

Commits on Jul 7, 2023

• MINOR: Fix typo in javadoc (apache#13972)

  Show description for fd5b300
  aneelkkhatri

  authored
  fd5b300

  Copy full SHA for fd5b300

Commits on Jul 3, 2023

• KAFKA-10199: Consider tasks in state updater when computing offset sums (apache#13925)

  Show description for 5c2492b
  cadonna

  authored
  5c2492b

  Copy full SHA for 5c2492b

Commits on Jun 30, 2023

• MINOR: Add JDK 20 CI build and remove some branch builds (apache#12948)

  Show description for 1f4cbc5
  ijuma

  authored
  1f4cbc5

  Copy full SHA for 1f4cbc5

Commits on Jun 29, 2023

• KAFKA-14936: Add Grace period logic to Stream Table Join (2/N) (apache#13855)

  Show description for 12be344
  wcarlson5

  authored
  12be344

  Copy full SHA for 12be344

• KAFKA-15053: Use case insensitive validator for security.protocol config (apache#13831)

  Show description for 0054168
  bogao007

  authored
  0054168

  Copy full SHA for 0054168

Commits on Jun 22, 2023

• MINOR: Fix lossy conversions flagged by Java 20 (apache#13582)

  Show description for 9c8aaa2
  ijuma

  authored
  9c8aaa2

  Copy full SHA for 9c8aaa2

Commits on Jun 20, 2023

• MINOR: fix typos for streams (apache#13888)

  Show description for 474053d
  berg223

  authored
  474053d

  Copy full SHA for 474053d

• KAFKA-7438: Migrate to Mockito in TimeOrderedCachingPersistentWindowStoreTest (apache#12739)

  Show description for 0e8c436
  shekhar-rajak

  authored
  0e8c436

  Copy full SHA for 0e8c436

Commits on Jun 19, 2023

• MINOR: fix doc typo of StreamsBuilder.addGlobalStore (apache#13871)

  Show description for 41a8e55
  iblislin

  authored
  41a8e55

  Copy full SHA for 41a8e55

Commits on Jun 15, 2023

• KAFKA-14133: Migrate StandbyTaskCreator mock in TaskManagerTest to Mockito (apache#13711)

  Show description for c5df47a
  clolov

  authored
  c5df47a

  Copy full SHA for c5df47a

Commits on Jun 14, 2023

• KAFKA-14936: Add On Disk Time Ordered Buffer (1/N) (apache#13756)

  Show description for 4a5d1b3
  wcarlson5

  authored
  4a5d1b3

  Copy full SHA for 4a5d1b3

• MINOR: remove unused field ProcessorNode#time (apache#13624)

  Show description for 044d058
  machi1990

  authored
  044d058

  Copy full SHA for 044d058

Commits on Jun 13, 2023

• KAFKA-14133: Migrate Admin mock in TaskManagerTest to Mockito (apache#13712)

  Show description for 7f0e455
  clolov

  authored
  7f0e455

  Copy full SHA for 7f0e455

Commits on Jun 11, 2023

• KAFKA-10199: Re-add revived tasks to the state updater after handling (apache#13829)

  Show description for 6fe74f7
  cadonna

  authored
  6fe74f7

  Copy full SHA for 6fe74f7

Commits on Jun 10, 2023

• KAFKA-14936: Change Time Ordered Buffer to not require Change<> 0/N (apache#13830)

  Show description for daba741
  wcarlson5

  authored
  daba741

  Copy full SHA for daba741

Commits on Jun 9, 2023

• MINOR: Move MockTime to server-common (apache#13823)

  Show description for 7eea2a3
  dajac

  authored
  7eea2a3

  Copy full SHA for 7eea2a3

Commits on Jun 7, 2023

• KAFKA-14539: Simplify StreamsMetadataState by replacing the Cluster metadata with partition info map (apache#13751)

  Show description for 513e1c6
  danicafine

  authored
  513e1c6

  Copy full SHA for 513e1c6

Commits on Jun 1, 2023

• KAFKA-12562: Fix KafkaStreams#store old references in comments (apache#13774)

  Show description for 4b46bb4
  milindmantri

  authored
  4b46bb4

  Copy full SHA for 4b46bb4

• KAFKA-14133: Migrate ActiveTaskCreator mock in TaskManagerTest to Mockito (apache#13681)

  Show description for 560ab2c
  mehbey

  authored
  560ab2c

  Copy full SHA for 560ab2c

Commits on May 21, 2023

• KAFKA-14862 (HOTFIX): Fix ConcurrentModificationException (apache#13734)

  Show description for e96a463
  mjsax

  authored
  e96a463

  Copy full SHA for e96a463

Commits on May 10, 2023

• HOTFIX: fix the VersionedKeyValueToBytesStoreAdapter#isOpen API (apache#13695)

  Show description for 6d2ad4a
  ableegoldman

  authored
  6d2ad4a

  Copy full SHA for 6d2ad4a

Commits on May 8, 2023

• HOTFIX: fix broken Streams upgrade system test (apache#13654)

  Show description for b40a7fc
  mjsax

  authored
  b40a7fc

  Copy full SHA for b40a7fc

• KAFKA-14133: Migrate ChangeLogReader mock in TaskManagerTest to Mockito (apache#13621)

  Show description for 2b98f85
  clolov

  authored
  2b98f85

  Copy full SHA for 2b98f85

Commits on May 2, 2023

• KAFKA-14133: Migrate topology builder mock in TaskManagerTest to mockito (apache#13529)

  Show description for 141c76a
  cadonna

  authored
  141c76a

  Copy full SHA for 141c76a

Commits on Apr 27, 2023

• KAFKA-14944: Reduce CompletedFetch#parseRecord() memory copy (apache#12545)

  Show description for dd6690a
  LinShunKang

  authored
  dd6690a

  Copy full SHA for dd6690a

Commits on Apr 24, 2023

• KAFKA-12446: update change encoding to use varint (apache#13533)

  Show description for 2557a4b
  mjsax

  authored
  2557a4b

  Copy full SHA for 2557a4b

• KAFKA-14834: [12/N] Minor code cleanups relating to versioned stores (apache#13615)

  Show description for ab8f285
  vcrfxia

  authored
  ab8f285

  Copy full SHA for ab8f285

• KAFKA-14862: Outer stream-stream join does not output all results with multiple input partitions (apache#13592)

  Show description for 6dcdb01
  mjsax

  authored
  6dcdb01

  Copy full SHA for 6dcdb01

Commits on Apr 19, 2023

• KAFKA-14834: [11/N] Update table joins to identify out-of-order records with isLatest (apache#13609)

  Show description for 11c8bf4
  vcrfxia

  authored
  11c8bf4

  Copy full SHA for 11c8bf4

Commits on Apr 18, 2023

• MINOR: rename internal FK-join processor classes (apache#13589)

  Show description for 3388adf
  mjsax

  authored
  3388adf

  Copy full SHA for 3388adf

Commits on Apr 14, 2023

• MINOR: remove unnecessary KeyValueMapper (apache#13545)

  Show description for bf3a5a3
  mjsax

  authored
  bf3a5a3

  Copy full SHA for bf3a5a3

• MINOR: improve ProductionExceptionHandler test (apache#13576)

  Show description for fc9df51
  philipnee

  authored
  fc9df51

  Copy full SHA for fc9df51

• Revert "KAFKA-14318: KIP-878, Introduce partition autoscaling configs (apache#12962)" (apache#13527)

  Show description for c958d87
  mjsax

  authored
  c958d87

  Copy full SHA for c958d87

• KAFKA-14054: Handle TimeoutException gracefully (apache#13534)

  Show description for 20028e2
  mjsax

  authored
  20028e2

  Copy full SHA for 20028e2

Pagination

Previous

Next