Repository navigation

Commits

Commits on Mar 8, 2018
- KAFKA-6560: [FOLLOW-UP] don't deserialize null byte array in window store fetch (#4665)
  
  dguy
  authored and
  guozhangwang
  committed
  989088f
Commits on Feb 20, 2018
- MINOR: Fix streams broker compatibility test.
  dguy
  committed
  57059d4
Commits on Feb 1, 2018
- Bump trunk versions to 1.2-SNAPSHOT (#4505)
  dguy
  authored
  ca01711
Commits on Dec 14, 2017
- KAFKA-6360: Clear RocksDB Segments when store is closed
  
  dguy
  authored and
  guozhangwang
  committed
  1cf7ec8
Commits on Dec 13, 2017
- KAFKA-6349: Fix concurrent modification exception in AbstractStateManager during restore
  
  dguy
  authored and
  guozhangwang
  committed
  d1a9252
- MINOR: Fix warn logging in RecordCollectorImpl
  
  dguy
  authored and
  guozhangwang
  committed
  fe3699c
Commits on Nov 22, 2017
- KAFKA-6214: enable use of in-memory store for standby tasks
  
  dguy
  authored and
  guozhangwang
  committed
  225b0b9
Commits on Oct 17, 2017
- MINOR: add equals to SessionWindows
  
  dguy
  authored and
  guozhangwang
  committed
  6c416ac
Commits on Oct 6, 2017
- KAFKA-5651; Follow-up: add with method to Materialized
  
  dguy
  authored and
  guozhangwang
  committed
  23a0140
Commits on Oct 5, 2017
- KAFKA-5989; resume consumption of tasks that have state stores but no changelogging
  dguy
  committed
  e61002e
Commits on Oct 4, 2017
- MINOR: update streams quickstart for KIP-182
  
  dguy
  authored and
  guozhangwang
  committed
  93b71e7
Commits on Oct 2, 2017
- MINOR: additional kip-182 doc updates
  dguy
  committed
  cc84686
Commits on Sep 29, 2017
- KAFKA-5986; Streams State Restoration never completes when logging is disabled
  dguy
  committed
  3107a6c
- MINOR: always set Serde.Long on count operations
  dguy
  committed
  082def0
Commits on Sep 28, 2017
- HOTFIX: fix build compilation error
  dguy
  committed
  9d0a89a
Commits on Sep 22, 2017
- KAFKA-5956; use serdes from materialized in table and globalTable
  dguy
  committed
  125d8d6
Commits on Sep 21, 2017
- MINOR: add upgrade note for KIP-173 topic configs
  
  dguy
  authored and
  guozhangwang
  committed
  f29391c
- KAFKA-5922: Add SessionWindowedKStream
  
  dguy
  authored and
  guozhangwang
  committed
  a2da064
Commits on Sep 20, 2017
- MINOR: change task initialization logging levels
  dguy
  committed
  bb98597
- KAFKA-5931; deprecate KTable#through and KTable#to
  dguy
  committed
  37ec15e
- MINOR: update release script for streams quickstart
  
  dguy
  authored and
  guozhangwang
  committed
  c587905
Commits on Sep 19, 2017
- MINOR: use StoreBuilder in KStreamImpl rather than StateStoreSupplier
  dguy
  committed
  c96f89f
- KAFKA-5921; add Materialized overloads to windowed kstream
  dguy
  committed
  c8f1471
Commits on Sep 18, 2017
- KAFKA-5873; add materialized overloads to StreamsBuilder
  dguy
  committed
  f2b74aa
- KAFKA-5515; Remove date formatting from Segments
  dguy
  committed
  ed0e692
- KAFKA-5654; add materialized count, reduce, aggregate to KGroupedStream
  dguy
  committed
  d83252e
Commits on Sep 15, 2017
- KAFKA-5908; fix range query in CompositeReadOnlyWindowStore
  dguy
  committed
  985cc53
Commits on Sep 13, 2017
- MINOR: update tutorial doc to match ak-site
  
  dguy
  authored and
  guozhangwang
  committed
  f7b1add
Commits on Sep 12, 2017
- KAFKA-5655; materialized count, aggregate, reduce to KGroupedTable
  dguy
  committed
  8bd2a68
- KAFKA:5653: add join overloads to KTable
  dguy
  committed
  08063f5
Commits on Sep 11, 2017
- KAFKA-5817: [FOLLOW-UP] add SerializedInternal
  
  dguy
  authored and
  guozhangwang
  committed
  d6fabb0
- KAFKA-5816; [FOLLOW UP] create ProducedInternal class
  dguy
  committed
  779714c
Commits on Sep 8, 2017
- MINOR: make Consumed copy ctor protected
  
  dguy
  authored and
  guozhangwang
  committed
  689a84c
- MINOR: make Printed copy ctor protected
  
  dguy
  authored and
  guozhangwang
  committed
  9cec410
- KAFKA-5852: Add filter, filterNot, mapValues and Materialized to KTable
  
  dguy
  authored and
  guozhangwang
  committed
  2db1e44

Branch selector

User selector

Datepicker

Commit history

Commits on Mar 8, 2018

Commits on Feb 20, 2018

Commits on Feb 1, 2018

Commits on Dec 14, 2017

Commits on Dec 13, 2017

Commits on Nov 22, 2017

Commits on Oct 17, 2017

Commits on Oct 6, 2017

Commits on Oct 5, 2017

Commits on Oct 4, 2017

Commits on Oct 2, 2017

Commits on Sep 29, 2017

Commits on Sep 28, 2017

Commits on Sep 22, 2017

Commits on Sep 21, 2017

Commits on Sep 20, 2017

Commits on Sep 19, 2017

Commits on Sep 18, 2017

Commits on Sep 15, 2017

Commits on Sep 13, 2017

Commits on Sep 12, 2017

Commits on Sep 11, 2017

Commits on Sep 8, 2017