Commits

Branch selector

 trunk

User selector

cadonna

Datepicker

All time

Commit History

Commits on Jan 22, 2025

• KAFKA-18518: Add processor to handle rebalance events (#18527)

  Show description for 239708f
  cadonna

  authored
  239708f

  Copy full SHA for 239708f

Commits on Jan 16, 2025

• KAFKA-18546: Use mocks instead of a real DNS lookup to the outside (#18565)

  Show description for 5c20aa1
  cadonna

  authored
  5c20aa1

  Copy full SHA for 5c20aa1

Commits on Jan 9, 2025

• KAFKA-18453: Add StreamsTopology class to group coordinator (#18446)

  Show description for 11459ae
  cadonna

  authored
  11459ae

  Copy full SHA for 11459ae

Commits on Jan 8, 2025

• KAFKA-18321: Add StreamsGroupMember, MemberState and Assignment classes (#18276)

  Show description for 624dd45
  cadonna

  authored
  624dd45

  Copy full SHA for 624dd45

Commits on Dec 19, 2024

• KAFKA-18284: Add group coordinator records for Streams rebalance protocol (#18228)

  Show description for 4a6c6d1
  cadonna

  authored
  4a6c6d1

  Copy full SHA for 4a6c6d1

• MINOR: Fix flaky state updater test (#18253)

  Show description for a0291a8
  cadonna

  authored
  a0291a8

  Copy full SHA for a0291a8

Commits on Nov 25, 2024

• MINOR: Add 3.8.x and 3.9.x to Streams compatibility matrix (#17937)

  Show description for 619ef63
  cadonna

  authored
  619ef63

  Copy full SHA for 619ef63

Commits on Oct 16, 2024

• MINOR: Fix flakiness in state updater unit tests (#16562)

  Show description for 3b619db
  cadonna

  authored
  3b619db

  Copy full SHA for 3b619db

Commits on Sep 13, 2024

• KAFKA-17489: Do not handle failed tasks as tasks to assign (#17115)

  Show description for 0035ac0
  cadonna

  authored
  0035ac0

  Copy full SHA for 0035ac0

Commits on Jul 11, 2024

• KAFKA-17098: Re-add task to state updater if transit to RUNNING fails (#16570)

  Show description for a0309be
  

  cadonna

  authored and

  jlprat

  committed
  a0309be

  Copy full SHA for a0309be

• KAFKA-17085: Handle tasks in state updater before tasks in task registry (#16555) (#16561)

  Show description for d7fbdcf
  cadonna

  authored
  d7fbdcf

  Copy full SHA for d7fbdcf

Commits on Jul 8, 2024

• KAFKA-10199: Close pending active tasks to init on partitions lost (#16545) (#16550)

  Show description for 25230b5
  cadonna

  authored
  25230b5

  Copy full SHA for 25230b5

Commits on Jun 12, 2024

• KAFKA-10199: Enable state updater by default (#16107)

  Show description for 39ffdea
  cadonna

  authored
  39ffdea

  Copy full SHA for 39ffdea

Commits on Jun 6, 2024

• KAFKA-16903: Consider produce error of different task (#16222)

  Show description for 8a2bc3a
  cadonna

  authored
  8a2bc3a

  Copy full SHA for 8a2bc3a

Commits on May 31, 2024

• Revert "KAFKA-16448: Add ProcessingExceptionHandler interface and implementations (#16090)" (#16142)

  Show description for 76d1f18
  cadonna

  authored
  76d1f18

  Copy full SHA for 76d1f18

Commits on May 30, 2024

• Revert "KAFKA-16448: Add ProcessingExceptionHandler in Streams configuration (#16092)" (#16141)

  Show description for fea3eeb
  cadonna

  authored
  fea3eeb

  Copy full SHA for fea3eeb

Commits on May 17, 2024

• MINOR: Migrate tests in o.a.k.streams to JUnit 5 (except KafkaStreamsTest) (#15942)

  Show description for 69fc4c5
  cadonna

  authored
  69fc4c5

  Copy full SHA for 69fc4c5

• KAFKA-16774: Delete flaky test since it is redundant (#15978)

  Show description for c58c21c
  cadonna

  authored
  c58c21c

  Copy full SHA for c58c21c

Commits on May 15, 2024

• KAFKA-7342: Migrate tests in remaining packages in o.a.k.streams (#15963)

  Show description for ba19eed
  cadonna

  authored
  ba19eed

  Copy full SHA for ba19eed

• KAFKA-10199: Remove queue-based remove from state updater (#15896)

  Show description for d2e6c86
  cadonna

  authored
  d2e6c86

  Copy full SHA for d2e6c86

Commits on May 13, 2024

• KAFKA-10199: Shutdown with new remove operation in state updater (#15894)

  Show description for 5439914
  cadonna

  authored
  5439914

  Copy full SHA for 5439914

• KAFKA-10199: Handle assignment with new remove operation in state updater (#15882)

  Show description for cfffe4e
  cadonna

  authored
  cfffe4e

  Copy full SHA for cfffe4e

Commits on May 8, 2024

• KAFKA-10199: Revoke tasks from state updater with new remove (#15871)

  Show description for f7b242f
  cadonna

  authored
  f7b242f

  Copy full SHA for f7b242f

Commits on May 7, 2024

• KAFKA-10199: Remove lost tasks in state updater with new remove (#15870)

  Show description for cb35ddc
  cadonna

  authored
  cb35ddc

  Copy full SHA for cb35ddc

Commits on May 6, 2024

• KAFKA-10199: Add remove operation with future to state updater (#15852)

  Show description for 366aeab
  cadonna

  authored
  366aeab

  Copy full SHA for 366aeab

Commits on May 3, 2024

• KAFKA-10199: Accept only one task per element in output queue for failed tasks (#15849)

  Show description for 240243b
  cadonna

  authored
  240243b

  Copy full SHA for 240243b

Commits on Apr 10, 2024

• MINOR: Remove dead code of metric forward-rate (#15686)

  Show description for 5c855be
  cadonna

  authored
  5c855be

  Copy full SHA for 5c855be

Commits on Mar 25, 2024

• KAFKA-16224: Do not retry committing if topic or partition deleted (#15581)

  Show description for da6bb36
  cadonna

  authored
  da6bb36

  Copy full SHA for da6bb36

Commits on Mar 12, 2024

• KAFKA-16227: Avoid IllegalStateException during fetch initialization (#15491)

  Show description for 58ddd69
  cadonna

  authored
  58ddd69

  Copy full SHA for 58ddd69

Commits on Mar 4, 2024

• KAFKA-16285: Make group metadata available when a new assignment is set (#15426)

  Show description for aa0443e
  cadonna

  authored
  aa0443e

  Copy full SHA for aa0443e

Commits on Feb 21, 2024

• KAFKA-16194: Do not return records from poll if group metadata unknown (#15369)

  Show description for 02ebfc6
  cadonna

  authored
  02ebfc6

  Copy full SHA for 02ebfc6

• HOTFIX: Fix compilation error in TransactionManagerTest (#15405)

  Show description for cc49fc7
  cadonna

  authored
  cc49fc7

  Copy full SHA for cc49fc7

Commits on Jan 17, 2024

• KAFKA-16139: Fix StreamsUpgradeTest (#15199)

  Show description for e563aad
  cadonna

  authored
  e563aad

  Copy full SHA for e563aad

Commits on Jan 10, 2024

• KAFKA-16098: Verify pending recycle action when standby is re-assigned (#15168)

  Show description for fbbfafe
  cadonna

  authored
  fbbfafe

  Copy full SHA for fbbfafe

Commits on Dec 21, 2023

• KAFKA-16017: Checkpoint restored offsets instead of written offsets (#15044)

  Show description for 19727f8
  cadonna

  authored
  19727f8

  Copy full SHA for 19727f8

Pagination

Previous

Next