Commits

Branch selector

 trunk

User selector

dguy

Datepicker

All time

Commit History

Commits on Mar 8, 2018

• KAFKA-6560: [FOLLOW-UP] don't deserialize null byte array in window store fetch (apache#4665)

  Show description for 989088f
  

  dguy

  authored and

  guozhangwang

  committed
  989088f

  Copy full SHA for 989088f

Commits on Feb 20, 2018

• MINOR: Fix streams broker compatibility test.

  Show description for 57059d4
  dguy

  committed
  57059d4

  Copy full SHA for 57059d4

Commits on Feb 1, 2018

• Bump trunk versions to 1.2-SNAPSHOT (apache#4505)

  dguy

  authored
  ca01711

  Copy full SHA for ca01711

Commits on Dec 14, 2017

• KAFKA-6360: Clear RocksDB Segments when store is closed

  Show description for 1cf7ec8
  

  dguy

  authored and

  guozhangwang

  committed
  1cf7ec8

  Copy full SHA for 1cf7ec8

Commits on Dec 13, 2017

• KAFKA-6349: Fix concurrent modification exception in AbstractStateManager during restore

  Show description for d1a9252
  

  dguy

  authored and

  guozhangwang

  committed
  d1a9252

  Copy full SHA for d1a9252

• MINOR: Fix warn logging in RecordCollectorImpl

  Show description for fe3699c
  

  dguy

  authored and

  guozhangwang

  committed
  fe3699c

  Copy full SHA for fe3699c

Commits on Nov 22, 2017

• KAFKA-6214: enable use of in-memory store for standby tasks

  Show description for 225b0b9
  

  dguy

  authored and

  guozhangwang

  committed
  225b0b9

  Copy full SHA for 225b0b9

Commits on Oct 17, 2017

• MINOR: add equals to SessionWindows

  Show description for 6c416ac
  

  dguy

  authored and

  guozhangwang

  committed
  6c416ac

  Copy full SHA for 6c416ac

Commits on Oct 6, 2017

• KAFKA-5651; Follow-up: add with method to Materialized

  Show description for 23a0140
  

  dguy

  authored and

  guozhangwang

  committed
  23a0140

  Copy full SHA for 23a0140

Commits on Oct 5, 2017

• KAFKA-5989; resume consumption of tasks that have state stores but no changelogging

  Show description for e61002e
  dguy

  committed
  e61002e

  Copy full SHA for e61002e

Commits on Oct 4, 2017

• MINOR: update streams quickstart for KIP-182

  Show description for 93b71e7
  

  dguy

  authored and

  guozhangwang

  committed
  93b71e7

  Copy full SHA for 93b71e7

Commits on Oct 2, 2017

• MINOR: additional kip-182 doc updates

  Show description for cc84686
  dguy

  committed
  cc84686

  Copy full SHA for cc84686

Commits on Sep 29, 2017

• KAFKA-5986; Streams State Restoration never completes when logging is disabled

  Show description for 3107a6c
  dguy

  committed
  3107a6c

  Copy full SHA for 3107a6c

• MINOR: always set Serde.Long on count operations

  Show description for 082def0
  dguy

  committed
  082def0

  Copy full SHA for 082def0

Commits on Sep 28, 2017

• HOTFIX: fix build compilation error

  Show description for 9d0a89a
  dguy

  committed
  9d0a89a

  Copy full SHA for 9d0a89a

Commits on Sep 22, 2017

• KAFKA-5956; use serdes from materialized in table and globalTable

  Show description for 125d8d6
  dguy

  committed
  125d8d6

  Copy full SHA for 125d8d6

Commits on Sep 21, 2017

• MINOR: add upgrade note for KIP-173 topic configs

  Show description for f29391c
  

  dguy

  authored and

  guozhangwang

  committed
  f29391c

  Copy full SHA for f29391c

• KAFKA-5922: Add SessionWindowedKStream

  Show description for a2da064
  

  dguy

  authored and

  guozhangwang

  committed
  a2da064

  Copy full SHA for a2da064

Commits on Sep 20, 2017

• MINOR: change task initialization logging levels

  Show description for bb98597
  dguy

  committed
  bb98597

  Copy full SHA for bb98597

• KAFKA-5931; deprecate KTable#through and KTable#to

  Show description for 37ec15e
  dguy

  committed
  37ec15e

  Copy full SHA for 37ec15e

• MINOR: update release script for streams quickstart

  Show description for c587905
  

  dguy

  authored and

  guozhangwang

  committed
  c587905

  Copy full SHA for c587905

Commits on Sep 19, 2017

• MINOR: use StoreBuilder in KStreamImpl rather than StateStoreSupplier

  Show description for c96f89f
  dguy

  committed
  c96f89f

  Copy full SHA for c96f89f

• KAFKA-5921; add Materialized overloads to windowed kstream

  Show description for c8f1471
  dguy

  committed
  c8f1471

  Copy full SHA for c8f1471

Commits on Sep 18, 2017

• KAFKA-5873; add materialized overloads to StreamsBuilder

  Show description for f2b74aa
  dguy

  committed
  f2b74aa

  Copy full SHA for f2b74aa

• KAFKA-5515; Remove date formatting from Segments

  Show description for ed0e692
  dguy

  committed
  ed0e692

  Copy full SHA for ed0e692

• KAFKA-5654; add materialized count, reduce, aggregate to KGroupedStream

  Show description for d83252e
  dguy

  committed
  d83252e

  Copy full SHA for d83252e

Commits on Sep 15, 2017

• KAFKA-5908; fix range query in CompositeReadOnlyWindowStore

  Show description for 985cc53
  dguy

  committed
  985cc53

  Copy full SHA for 985cc53

Commits on Sep 13, 2017

• MINOR: update tutorial doc to match ak-site

  Show description for f7b1add
  

  dguy

  authored and

  guozhangwang

  committed
  f7b1add

  Copy full SHA for f7b1add

Commits on Sep 12, 2017

• KAFKA-5655; materialized count, aggregate, reduce to KGroupedTable

  Show description for 8bd2a68
  dguy

  committed
  8bd2a68

  Copy full SHA for 8bd2a68

• KAFKA:5653: add join overloads to KTable

  Show description for 08063f5
  dguy

  committed
  08063f5

  Copy full SHA for 08063f5

Commits on Sep 11, 2017

• KAFKA-5817: [FOLLOW-UP] add SerializedInternal

  Show description for d6fabb0
  

  dguy

  authored and

  guozhangwang

  committed
  d6fabb0

  Copy full SHA for d6fabb0

• KAFKA-5816; [FOLLOW UP] create ProducedInternal class

  Show description for 779714c
  dguy

  committed
  779714c

  Copy full SHA for 779714c

Commits on Sep 8, 2017

• MINOR: make Consumed copy ctor protected

  Show description for 689a84c
  

  dguy

  authored and

  guozhangwang

  committed
  689a84c

  Copy full SHA for 689a84c

• MINOR: make Printed copy ctor protected

  Show description for 9cec410
  

  dguy

  authored and

  guozhangwang

  committed
  9cec410

  Copy full SHA for 9cec410

• KAFKA-5852: Add filter, filterNot, mapValues and Materialized to KTable

  Show description for 2db1e44
  

  dguy

  authored and

  guozhangwang

  committed
  2db1e44

  Copy full SHA for 2db1e44

Pagination

Previous

Next