Commits

Branch selector

 trunk

User selector

jeqo

All time

Commit History

Commits on Nov 21, 2022

• KAFKA-14325: Fix NPE on Processor Parameters toString (#12859)

  Show description for 0de0374
  jeqo

  authored
  0de0374

  Copy full SHA for 0de0374

Commits on Apr 19, 2022

• KAFKA-13654: Extend KStream process with new Processor API (#11993)

  Show description for fa03244
  jeqo

  authored
  fa03244

  Copy full SHA for fa03244

Commits on Apr 11, 2022

• MINOR: Fix SessionStore#fetchSession parameter names (#11999)

  Show description for 0d518aa
  jeqo

  authored
  0d518aa

  Copy full SHA for 0d518aa

Commits on Feb 12, 2022

• KAFKA-12939: After migrating processors, search the codebase for missed migrations (#11534)

  Show description for 9931036
  jeqo

  authored
  9931036

  Copy full SHA for 9931036

Commits on Nov 23, 2021

• KAFKA-13117: migrate TupleForwarder and CacheFlushListener to new Record API (#11481)

  Show description for 1e09165
  jeqo

  authored
  1e09165

  Copy full SHA for 1e09165

Commits on Nov 10, 2021

• KAFKA-13429: ignore bin on new modules (#11415)

  Show description for 214b59b
  jeqo

  authored
  214b59b

  Copy full SHA for 214b59b

Commits on Nov 8, 2021

• KAFKA-10543: Convert KTable joins to new PAPI (#11412)

  Show description for 807c5b4
  jeqo

  authored
  807c5b4

  Copy full SHA for 807c5b4

Commits on Oct 18, 2021

• KAFKA-10539: Convert KStreamImpl joins to new PAPI (#11356)

  Show description for 68223d3
  jeqo

  authored
  68223d3

  Copy full SHA for 68223d3

Commits on Sep 30, 2021

• KAFKA-10540: Migrate KStream aggregate operations (#11315)

  Show description for ce83e5b
  jeqo

  authored
  ce83e5b

  Copy full SHA for ce83e5b

Commits on Sep 22, 2021

• KAFKA-10544: Migrate KTable aggregate and reduce (#11316)

  Show description for d15969a
  jeqo

  authored
  d15969a

  Copy full SHA for d15969a

Commits on Sep 7, 2021

• KAFKA-13201: Convert KTable suppress to new PAPI (#11213)

  Show description for 5f89ce5
  jeqo

  authored
  5f89ce5

  Copy full SHA for 5f89ce5

Commits on Jul 29, 2021

• KAFKA-10542: Migrate KTable mapValues, passthrough, and source to new Processor API (#11099)

  Show description for 3190ebd
  jeqo

  authored
  3190ebd

  Copy full SHA for 3190ebd

Commits on May 7, 2021

• KAFKA-12536: Add Instant-based methods to ReadOnlySessionStore (#10390)

  Show description for 8f8f914
  jeqo

  authored
  8f8f914

  Copy full SHA for 8f8f914

Commits on May 6, 2021

• KAFKA-12451: Remove deprecation annotation on long-based read operations in WindowStore (#10296)

  Show description for 12a1e68
  jeqo

  authored
  12a1e68

  Copy full SHA for 12a1e68

Commits on May 4, 2021

• KAFKA-12450: Remove deprecated methods from ReadOnlyWindowStore (#10294)

  Show description for 45f24c4
  jeqo

  authored
  45f24c4

  Copy full SHA for 45f24c4

Commits on Apr 9, 2021

• KAFKA-8410: Migrate KStream Stateless operators to new Processor API (#10381)

  Show description for c9cab2b
  jeqo

  authored
  c9cab2b

  Copy full SHA for c9cab2b

• KAFKA-12449: Remove deprecated WindowStore#put (#10293)

  Show description for db0323e
  jeqo

  authored
  db0323e

  Copy full SHA for db0323e

Commits on Mar 11, 2021

• KAFKA-12287: Add WARN logging on consumer-groups when reset-offsets by timestamp or duration can't find an offset and defaults to latest (#10092)

  Show description for c534bf4
  jeqo

  authored
  c534bf4

  Copy full SHA for c534bf4

Commits on Oct 8, 2020

• KAFKA-9929: Support backward iterator on SessionStore (#9139)

  Show description for d0e6943
  jeqo

  authored
  d0e6943

  Copy full SHA for d0e6943

Commits on Oct 6, 2020

• KAFKA-9929: fix: add missing default implementations (#9321)

  Show description for 5a5d1c3
  jeqo

  authored
  5a5d1c3

  Copy full SHA for 5a5d1c3

Commits on Sep 2, 2020

• KAFKA-9929: Support backward iterator on WindowStore (#9138)

  Show description for 4f06d9e
  jeqo

  authored
  4f06d9e

  Copy full SHA for 4f06d9e

Commits on Aug 22, 2020

• KAFKA-9929: Support reverse iterator on KeyValueStore (#9137)

  Show description for 89d0678
  jeqo

  authored
  89d0678

  Copy full SHA for 89d0678

Commits on Jun 30, 2020

• MINOR: Fix typo in ssl.client.auth config doc description (#8956)

  Show description for 1e1aa4a
  jeqo

  authored
  1e1aa4a

  Copy full SHA for 1e1aa4a

Commits on May 1, 2020

• MINOR: Use `firstTimestamp` instead of `baseTimestamp` in docs (#8584)

  Show description for 4803c77
  jeqo

  authored
  4803c77

  Copy full SHA for 4803c77

Commits on Apr 28, 2020

• MINOR: Fix partition numbering from 0 to P-1 instead of P in docs (#8572)

  Show description for 57961c3
  jeqo

  authored
  57961c3

  Copy full SHA for 57961c3

Commits on Jun 4, 2018

• KAFKA-6938: Add documentation for accessing Headers on Kafka Streams Processor API (#5128)

  Show description for e8ddb76
  

  jeqo

  authored and

  guozhangwang

  committed
  e8ddb76

  Copy full SHA for e8ddb76

Commits on May 22, 2018

• KAFKA-6850: Add Record Header support to Kafka Streams Processor API (KIP-244) (#4955)

  Show description for 133108c
  

  jeqo

  authored and

  mjsax

  committed
  133108c

  Copy full SHA for 133108c

Commits on Apr 11, 2018

• KAFKA-6058: KIP-222; Add Consumer Group operations to Admin API

  Show description for 6a99da8
  

  jeqo

  authored and

  guozhangwang

  committed
  6a99da8

  Copy full SHA for 6a99da8

Commits on Jan 8, 2018

• Updating docs for streams app reset tool (#4401)

  Show description for 2900af6
  

  jeqo

  authored and

  guozhangwang

  committed
  2900af6

  Copy full SHA for 2900af6

Commits on Dec 6, 2017

• KAFKA-5520: KIP-171; Extend Consumer Group Reset Offset for Stream Application

  Show description for 30f08d1
  

  jeqo

  authored and

  guozhangwang

  committed
  30f08d1

  Copy full SHA for 30f08d1

Commits on May 31, 2017

• KAFKA-5266; Follow-up improvements for consumer offset reset tool (KIP-122)

  Show description for ef95512
  

  jeqo

  authored and

  hachikuji

  committed
  ef95512

  Copy full SHA for ef95512

Commits on May 17, 2017

• KAFKA-4743; [KIP-122] Add Reset Consumer Group Offsets tooling

  Show description for 2181ae7
  

  jeqo

  authored and

  hachikuji

  committed
  2181ae7

  Copy full SHA for 2181ae7