Commits

Branch selector

 trunk

User selector

All users

Datepicker

All time

Commit History

Commits on Aug 2, 2017

• KAFKA-5096; Log invalid user configs and use defaults

  Show description for b7684b4
  

  johnma14

  authored and

  dguy

  committed
  b7684b4

Commits on Aug 1, 2017

• KAFKA-3623: KStreamTestDriver extends ExternalResource

  Show description for edcefcc
  

  johnma14

  authored and

  guozhangwang

  committed
  edcefcc

• HOTFIX: handle commit failed exception on stream thread's suspend task

  Show description for 228a4fd
  guozhangwang

  committed
  228a4fd

• KAFKA-5454: Add a new Kafka Streams example IoT oriented

  Show description for 94a6d6c
  

  ppatierno

  authored and

  guozhangwang

  committed
  94a6d6c

• MINOR: Request log should be enabled by debug level

  Show description for 4086db4
  

  ijuma

  authored and

  Jason Gustafson

  committed
  4086db4

• KAFKA-5630; Consumer should block on corrupt records and keep throwing an exception

  Show description for cd4c6c0
  

  becketqin

  authored and

  Jason Gustafson

  committed
  cd4c6c0

Commits on Jul 31, 2017

• KAFKA-5671: Add StreamsBuilder and Deprecate KStreamBuilder

  Show description for da22055
  

  mjsax

  authored and

  guozhangwang

  committed
  da22055

Commits on Jul 28, 2017

• KAFKA-5670: (KIP-120) Add Topology and deprecate TopologyBuilder

  Show description for 1844bf2
  

  mjsax

  authored and

  guozhangwang

  committed
  1844bf2

• KAFKA-5363 (KIP-167): implementing bulk load, restoration event notification

  Show description for c50c941
  

  bbejeck

  authored and

  guozhangwang

  committed
  c50c941

• KAFKA-5341; Add UnderMinIsrPartitionCount and per-partition UnderMinIsr metrics (KIP-164)

  Show description for 4003c93
  

  lindong28

  authored and

  ewencp

  committed
  4003c93

• HOTFIX: fix threading issue in MeteredKeyValueStore

  Show description for 4059fa5
  dguy

  committed
  4059fa5

Commits on Jul 27, 2017

• KAFKA-5634; Do not allow segment deletion beyond high watermark

  Show description for 6bd7302
  

  Jason Gustafson

  committed
  6bd7302

• KAFKA-5549; Explain that 'client.id' is just used as a prefix within Streams

  Show description for 9d6020e
  

  PranavManiar

  authored and

  dguy

  committed
  9d6020e

• KAFKA-1595; Remove deprecated and slower Scala JSON parser

  Show description for 8b14e11
  ijuma

  committed
  8b14e11

• KAFKA-5611; AbstractCoordinator should handle wakeup raised from onJoinComplete

  Show description for 3620035
  

  Jason Gustafson

  committed
  3620035

Commits on Jul 26, 2017

• MINOR: Next release will be 1.0.0

  Show description for 5effe72
  

  ijuma

  authored and

  guozhangwang

  committed
  5effe72

• MINOR: updated configs to use one try/catch for serdes

  Show description for f8498ec
  

  bbejeck

  authored and

  guozhangwang

  committed
  f8498ec

• MINOR: Fix typo in SMT doc: s/RegexpRouter/RegexRouter

  Show description for f4d1305
  

  rmoff

  authored and

  ewencp

  committed
  f4d1305

• KAFKA-5562; execute state dir cleanup on single thread

  Show description for 9f3f8b4
  dguy

  committed
  9f3f8b4

• MINOR: enforce setting listeners in CREATE state.

  Show description for 89faed8
  

  bbejeck

  authored and

  dguy

  committed
  89faed8

• KAFKA-5501; introduce async ZookeeperClient

  Show description for e5e88f6
  

  onurkaraman

  authored and

  junrao

  committed
  e5e88f6

• KAFKA-4602; KIP-72 - Allow putting a bound on memory consumed by Incoming requests

  Show description for 47ee8e9
  

  radai-rosenblatt

  authored and

  junrao

  committed
  47ee8e9

• KAFKA-5627; Reduce classes needed for LeaderAndIsrPartitionState and MetadataPartitionState

  Show description for f15cdbc
  

  lindong28

  authored and

  becketqin

  committed
  f15cdbc

Commits on Jul 25, 2017

• MINOR: Make streams quick start more interactive

  Show description for 91c207c
  guozhangwang

  committed
  91c207c

Commits on Jul 24, 2017

• KAFKA-3856 (KIP-120) step two: extract internal functions from public facing TopologyBuilder class

  Show description for 5d79851
  

  mjsax

  authored and

  guozhangwang

  committed
  5d79851

Commits on Jul 22, 2017

• KAFKA-4763; Handle disk failure for JBOD (KIP-112)

  Show description for fc93fb4
  

  lindong28

  authored and

  becketqin

  committed
  fc93fb4

• MINOR: Give correct instructions for retaining previous unclear leader election behaviour

  Show description for 91b5fc7
  ijuma

  committed
  91b5fc7

• MINOR: Improve log warning to include the log name

  Show description for 7727d7a
  ijuma

  committed
  7727d7a

• MINOR: Don't imply that ConsumerGroupCommand won't work with non-Java clients

  Show description for c71e7fa
  ewencp

  committed
  c71e7fa

• MINOR: Add Streams landing page

  Show description for 300f480
  

  derrickdoo

  authored and

  guozhangwang

  committed
  300f480

Commits on Jul 21, 2017

• KAFKA-5481: ListOffsetResponse isn't logged in the right way with trace level enabled

  Show description for 6c6cf01
  

  ppatierno

  authored and

  ewencp

  committed
  6c6cf01

• MINOR: Added safe deserialization implementation

  Show description for da42977
  

  Hooman Broujerdi

  authored and

  ewencp

  committed
  da42977

• KAFKA-5512; Awake the heartbeat thread when timetoNextHeartbeat is equal to 0

  Show description for 4a7064d
  

  rosets

  authored and

  Jason Gustafson

  committed
  4a7064d

• KAFKA-5608; Follow-up to fix potential NPE and clarify method name

  Show description for 08b775c
  ijuma

  committed
  08b775c

• KAFKA-3741; allow users to specify default topic configs for internal topics

  Show description for 1110f66
  dguy

  committed
  1110f66

Pagination

PreviousNext