Commits

Branch selector

 trunk

User selector

All users

All time

Commit History

Commits on Feb 23, 2016

• KAFKA-3272: Add debugging options to kafka-run-class.sh so we can easily run remote debugging

  

  christian-posta

  authored and

  gwenshap

  committedFeb 23, 2016
  aeb9c2a

• KAFKA-3007: implement max.poll.records (KIP-41)

  

  hachikuji

  authored and

  ewencp

  committedFeb 23, 2016
  73ecd7a

• HOTFIX: Add missing file for KeyValue unit test

  

  guozhangwang

  authored and

  gwenshap

  committedFeb 23, 2016
  c00a036

• MINOR: KTable.count() to only take a selector for key

  

  guozhangwang

  authored and

  gwenshap

  committedFeb 23, 2016
  0ce9163

• KAFKA-3046: Add ByteBuffer Serializer and Deserializer

  

  vesense

  authored and

  guozhangwang

  committedFeb 23, 2016
  14b688e

• HOTFIX: fix consumer config for streams

  

  Yasuhiro Matsuda

  authored and

  guozhangwang

  committedFeb 23, 2016
  f7fe9cc

• KAFKA-3245: config for changelog replication factor

  

  Yasuhiro Matsuda

  authored and

  guozhangwang

  committedFeb 23, 2016
  878b78a

• KAFKA-3242: minor rename / logging change to Controller

  

  benstopford

  authored and

  gwenshap

  committedFeb 23, 2016
  525f4c8

• KAFKA-2802: kafka streams system tests

  

  Yasuhiro Matsuda

  authored and

  ewencp

  committedFeb 23, 2016
  3358e16

• MINOR: catch a commit failure due to rebalance in StreamThread

  

  Yasuhiro Matsuda

  authored and

  guozhangwang

  committedFeb 23, 2016
  68af16a

• HOTFIX: check offset limits in streamtask when recovering KTable store

  

  Yasuhiro Matsuda

  authored and

  guozhangwang

  committedFeb 23, 2016
  982ab09

• MINOR - remove unused imports in package kafka.utils

  

  zhuchen1018

  authored and

  jjkoshy

  committedFeb 23, 2016
  04585d9

Commits on Feb 22, 2016

• KAFKA-3256; Add print.timestamp option to console consumer.

  

  becketqin

  authored and

  junrao

  committedFeb 22, 2016
  d142f82

• HOTFIX: make sure to go through all shutdown steps

  

  Yasuhiro Matsuda

  authored and

  guozhangwang

  committedFeb 22, 2016
  ff7b0f5

• MINOR: Update streams RocksDb to 4.1.0

  

  ijuma

  authored and

  guozhangwang

  committedFeb 22, 2016
  46e4d40

• MINOR: Example style improvements

  

  ijuma

  authored and

  gwenshap

  committedFeb 22, 2016
  e3ab96b

• KAFKA-3255: Added unit tests for NetworkClient.connectionDelay(Node node, long now)

  

  frankscholten

  authored and

  ewencp

  committedFeb 22, 2016
  d2527af

• KAFKA-3235: Unclosed stream in AppInfoParser static block

  

  Kim Christensen

  authored and

  gwenshap

  committedFeb 22, 2016
  49fd0ce

• inor: Added few variable and their descriptions to vagrant readme

  

  christian-posta

  authored and

  gwenshap

  committedFeb 22, 2016
  6ebb236

Commits on Feb 19, 2016

• trivial fix to authorization CLI table

  junrao

  committedFeb 19, 2016
  5caa800

• KAFKA-3025; Added timetamp to Message and use relative offset.

  

  becketqin

  authored and

  junrao

  committedFeb 19, 2016
  45c8195

Commits on Feb 18, 2016

• MINOR: remove streams config params from producer/consumer configs

  

  Yasuhiro Matsuda

  authored and

  guozhangwang

  committedFeb 18, 2016
  eee9522

Commits on Feb 17, 2016

• KAFKA-3225: Method commit() of class SourceTask never invoked

  

  jcustenborder

  authored and

  ewencp

  committedFeb 17, 2016
  8c90b1a

• KAFKA-2757; Consolidate BrokerEndPoint and EndPoint

  

  zhuchen1018

  authored and

  guozhangwang

  committedFeb 17, 2016
  3382b6d

• KAFKA-2547; Make DynamicConfigManager to use the ZkNodeChangeNotifica…

  

  Parth-Brahmbhatt

  authored and

  Sriharsha Chintalapani

  committedFeb 17, 2016
  2faf9f6

• KAFKA-2508; Replace UpdateMetadata{Request,Response} with o.a.k.c.req…

  

  granthenke

  authored and

  Sriharsha Chintalapani

  committedFeb 17, 2016
  5df5614

Commits on Feb 16, 2016

• MINOR: Reconcile differences in .bat & .sh start scripts

  

  fluetm

  authored and

  ewencp

  committedFeb 16, 2016
  3ee1878

• KAFKA-3227; Conservative update of Kafka dependencies

  

  ijuma

  authored and

  ewencp

  committedFeb 16, 2016
  f355918

Commits on Feb 13, 2016

• KAFKA-3088; Make client-id a nullable string and fix handling of invalid requests."

  

  granthenke

  authored and

  jjkoshy

  committedFeb 13, 2016
  d7fc7cf

Commits on Feb 12, 2016

• KAFKA-3147; Memory records is not writable in MirrorMaker

  

  Mayuresh Gharat

  authored and

  guozhangwang

  committedFeb 12, 2016
  85599bc

• MINOR: catch an exception in rebalance and stop the stream thread

  

  Yasuhiro Matsuda

  authored and

  guozhangwang

  committedFeb 12, 2016
  f141e64

Commits on Feb 11, 2016

• KAFKA-3229 ensure that root statestore is registered with ProcessorStateManager

  

  tomdearman

  authored and

  gwenshap

  committedFeb 11, 2016
  330274e

• MINOR: add setUncaughtExceptionHandler to KafkaStreams

  

  Yasuhiro Matsuda

  authored and

  ewencp

  committedFeb 11, 2016
  67a7ea9

• MINOR: Connect hangs on startup failure

  

  hachikuji

  authored and

  ewencp

  committedFeb 11, 2016
  5092e7f

Commits on Feb 10, 2016

• HOTFIX: poll even when all partitions are paused. handle concurrent cleanup

  

  Yasuhiro Matsuda

  authored and

  gwenshap

  committedFeb 10, 2016
  c1f8f68

Pagination

PreviousNext