Commits

Commits on Jul 13, 2021

KAFKA-8410: Update the docs to reference the new PAPI (apache#10994 )
vvcephei
authoredJul 13, 2021

Commits on Jul 12, 2021

KAFKA-12360: Document new time semantics (apache#11003 )
vvcephei
authoredJul 12, 2021

Commits on Jun 22, 2021

KAFKA-10546: Deprecate old PAPI (apache#10869 )
vvcephei
authoredJun 22, 2021

Commits on Jun 14, 2021

MINOR: enable EOS during smoke test IT (apache#10870 )
vvcephei
authoredJun 14, 2021

Commits on May 28, 2021

KAFKA-8410: KTableProcessor migration groundwork (apache#10744 )
vvcephei
authoredMay 28, 2021

Commits on Apr 6, 2021

KAFKA-12602: Fix LICENSE file (apache#10474 )
vvcephei
authoredApr 6, 2021

Commits on Apr 1, 2021

KAFKA-12593: Fix Apache License headers (apache#10452 )
vvcephei
authoredApr 1, 2021

Commits on Mar 30, 2021

KAFKA-12557: Fix hanging KafkaAdminClientTest (apache#10404 )
vvcephei
authoredMar 30, 2021

Commits on Mar 25, 2021

KAFKA-12508: Disable KIP-557 (apache#10397 )
vvcephei
authoredMar 25, 2021

Commits on Mar 24, 2021

KAFKA-12435: Fix javadoc errors (apache#10392 )
vvcephei
authoredMar 24, 2021

Commits on Mar 22, 2021

KAFKA-12514: Fix NPE in SubscriptionState (apache#10369 )
vvcephei
authoredMar 22, 2021

Commits on Mar 2, 2021

KAFKA-12268: Implement task idling semantics via currentLag API (apache#10137 )
vvcephei
authoredMar 2, 2021

Commits on Jan 28, 2021

KAFKA-10867: Improved task idling (apache#9840 )
vvcephei
authoredJan 28, 2021
KAFKA-10866: Add metadata to ConsumerRecords (apache#9836 )
vvcephei
authoredJan 28, 2021

Commits on Jan 19, 2021

MINOR: Fix StreamsOptimizedTest (apache#9911 )
vvcephei
authoredJan 19, 2021

Commits on Oct 29, 2020

MINOR: Fix flaky shouldRejectNonExistentStoreName (apache#9426 )
vvcephei
authoredOct 29, 2020
KAFKA-10638: Fix QueryableStateIntegrationTest (apache#9521 )
vvcephei
authoredOct 29, 2020

Commits on Oct 22, 2020

MINOR: TopologyTestDriver should not require dummy parameters (apache#9477 )
vvcephei
authoredOct 22, 2020

Commits on Oct 19, 2020

KAFKA-10605: Deprecate old PAPI registration methods (apache#9448 )
vvcephei
authoredOct 19, 2020

Commits on Oct 13, 2020

KAFKA-10437: Implement new PAPI support for test-utils (apache#9396 )
vvcephei
authoredOct 13, 2020

Commits on Oct 12, 2020

KAFKA-10598: Improve IQ name and type checks (apache#9408 )
vvcephei
authoredOct 12, 2020

Commits on Oct 8, 2020

KAFKA-10562: Properly invoke new StateStoreContext init (apache#9388 )
vvcephei
authoredOct 8, 2020

Commits on Oct 2, 2020

KAFKA-10535: Split ProcessorContext into Processor/StateStore/Record Contexts (apache#9361 )
vvcephei
authoredOct 2, 2020

Commits on Sep 24, 2020

MINOR: clarify variables for skipping idempotent source updates (apache#9316 )
vvcephei
authoredSep 24, 2020

Commits on Sep 10, 2020

MINOR: Add debug logs for StreamThread (apache#9267 )
vvcephei
authoredSep 10, 2020

Commits on Sep 9, 2020

KAFKA-10436: Implement KIP-478 Topology changes (apache#9221 )
vvcephei
authoredSep 9, 2020

Commits on Sep 3, 2020

MINOR: Record all poll invocations (apache#9234 )
vvcephei
authoredSep 3, 2020

Commits on Aug 20, 2020

KAFKA-10379: Implement the KIP-478 StreamBuilder#addGlobalStore() (apache#9148 )
vvcephei
authoredAug 20, 2020

Commits on Aug 11, 2020

MINOR: bump 2.5 versions to 2.5.1 (apache#9165 )
vvcephei
authoredAug 11, 2020

Commits on Aug 10, 2020

KAFKA-10261: Introduce the KIP-478 apis with adapters (apache#9004 )
vvcephei
authoredAug 10, 2020

Commits on Aug 5, 2020

MINOR: Streams integration tests should not call exit (apache#9067 )
vvcephei
authoredAug 5, 2020

Commits on Jul 24, 2020

MINOR: speed up release script (apache#9070 )
vvcephei
authoredJul 24, 2020
MINOR: add task ':streams:testAll' (apache#9073 )
vvcephei
authoredJul 24, 2020

Commits on Jul 11, 2020

KAFKA-10247: Correctly reset state when task is corrupted (apache#8994 )
vvcephei
authoredJul 11, 2020

Commits on Jul 6, 2020

MINOR: prune the metadata upgrade test matrix (apache#8971 )
vvcephei
authoredJul 6, 2020