Commits

Branch selector

 trunk

User selector

cadonna

Datepicker

All time

Commit History

Commits on Apr 23, 2025

• KAFKA-19124: Follow up on code improvements (#19453)

  Show description for efd7852
  cadonna

  authored
  efd7852

  Copy full SHA for efd7852

Commits on Apr 10, 2025

• KAFKA-19124: Use consumer background event queue for Streams events (#19421)

  Show description for c11938c
  cadonna

  authored
  c11938c

  Copy full SHA for c11938c

Commits on Apr 9, 2025

• KAFKA-19037: Integrate consumer-side code with Streams (#19377)

  Show description for 2a370ed
  cadonna

  authored
  2a370ed

  Copy full SHA for 2a370ed

Commits on Apr 4, 2025

• MINOR: Consider repartition source topic for changelog topics (#19373)

  Show description for 36c2fac
  cadonna

  authored
  36c2fac

  Copy full SHA for 36c2fac

Commits on Apr 3, 2025

• MINOR: Deduplicate topics of a topology for authorization check (#19352)

  Show description for 6ef42d1
  cadonna

  authored
  6ef42d1

  Copy full SHA for 6ef42d1

Commits on Mar 25, 2025

• KAFKA-18736: Add pollOnClose() and maximumTimeToWait() (#19233)

  Show description for 96196bb
  cadonna

  authored
  96196bb

  Copy full SHA for 96196bb

Commits on Mar 24, 2025

• KAFKA-18736: Handle errors in the Streams group heartbeat request manager (#19230)

  Show description for 266532f
  cadonna

  authored
  266532f

  Copy full SHA for 266532f

Commits on Mar 16, 2025

• KAFKA-18736: Do not send fields if not needed (#19181)

  Show description for a7e40b7
  cadonna

  authored
  a7e40b7

  Copy full SHA for a7e40b7

Commits on Mar 11, 2025

• MINOR: Downgrade log messages of swallowed exception to warnings (#19185)

  Show description for 8117617
  cadonna

  authored
  8117617

  Copy full SHA for 8117617

Commits on Mar 10, 2025

• KAFKA-18736: Decide when a heartbeat should be sent (#19121)

  Show description for 59e5890
  cadonna

  authored
  59e5890

  Copy full SHA for 59e5890

Commits on Mar 3, 2025

• HOTFIX: Revert "KAFKA-18067: Kafka Streams can leak Producer client under EOS (#17931)" (#19078)

  Show description for ff94c44
  cadonna

  authored
  ff94c44

  Copy full SHA for ff94c44

• MINOR: Extract HeartbeatRequestState from heartbeat request managers (#19043)

  Show description for 898dcd1
  cadonna

  authored
  898dcd1

  Copy full SHA for 898dcd1

Commits on Feb 18, 2025

• KAFKA-18736: Add Streams group heartbeat request manager (1/N) (#18870)

  Show description for d6b6952
  cadonna

  authored
  d6b6952

  Copy full SHA for d6b6952

Commits on Feb 4, 2025

• KAFKA-18538: Add Streams membership manager (#18551)

  Show description for b998189
  cadonna

  authored
  b998189

  Copy full SHA for b998189

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

Pagination

Previous

Next