Commits

Branch selector

 trunk

User selector

All users

Datepicker

All time

Commit History

Commits on Jul 19, 2016

• MINOR: Fix typo in Operations section

  Show description for 0744449
  

  ssaamm

  authored and

  ijuma

  committed
  0744449

  Copy full SHA for 0744449

• MINOR: Doc of 'retries' config should mention max.in.flight.requests.per.connection to avoid confusion

  Show description for 7354cc1
  

  kawamuray

  authored and

  ijuma

  committed
  7354cc1

  Copy full SHA for 7354cc1

Commits on Jul 18, 2016

• MINOR: Added simple streams benchmark to system tests

  Show description for 61c568d
  

  enothereska

  authored and

  guozhangwang

  committed
  61c568d

  Copy full SHA for 61c568d

• KAFKA-3870: Expose state store names in DSL

  Show description for fbc5185
  

  enothereska

  authored and

  guozhangwang

  committed
  fbc5185

  Copy full SHA for fbc5185

Commits on Jul 15, 2016

• KAFKA-3952: Consumer rebalance verifier never succeed due to type mismatch

  Show description for 7a70c1a
  

  wanwenli

  authored and

  guozhangwang

  committed
  7a70c1a

  Copy full SHA for 7a70c1a

Commits on Jul 14, 2016

• KAFKA-3905: Handling null/empty topics and collections, patterns when subscription with list of topics or with patterns, and with assignments.

  Show description for 9f94a77
  

  rekhajoshm

  authored and

  ijuma

  committed
  9f94a77

  Copy full SHA for 9f94a77

• KAFKA-3941: Delay eviction listener in InMemoryKeyValueLoggedStore after restoration

  Show description for f17790c
  guozhangwang

  committed
  f17790c

  Copy full SHA for f17790c

Commits on Jul 12, 2016

• MINOR: Check null in SmokeTestDriver to avoid NPE

  Show description for 3537063
  guozhangwang

  committed
  3537063

  Copy full SHA for 3537063

• KAFKA-3931: Fix transient failures in pattern subscription tests

  Show description for 98dfc4b
  

  vahidhashemian

  authored and

  guozhangwang

  committed
  98dfc4b

  Copy full SHA for 98dfc4b

• KAFKA-2945; CreateTopic - protocol and server side implementation

  Show description for fc47b9f
  

  granthenke

  authored and

  junrao

  committed
  fc47b9f

  Copy full SHA for fc47b9f

Commits on Jul 11, 2016

• KAFKA-3887 Follow-up: add unit test for null checking in KTable aggregates

  Show description for 136a8fa
  guozhangwang

  committed
  136a8fa

  Copy full SHA for 136a8fa

• KAFKA-3562; Handle topic deletion during a send

  Show description for c439268
  

  rajinisivaram

  authored and

  ijuma

  committed
  c439268

  Copy full SHA for c439268

• KAFKA-3942; Change IntegrationTestUtils.purgeLocalStreamsState to use java.io.tmpdir

  Show description for 383cec9
  

  dguy

  authored and

  ijuma

  committed
  383cec9

  Copy full SHA for 383cec9

• KAFKA-3725; Update documentation with regards to XFS

  Show description for e0eaa7f
  

  Todd Palino

  authored and

  ijuma

  committed
  e0eaa7f

  Copy full SHA for e0eaa7f

• KAFKA-2941: Clarify docs for key and value Converters

  Show description for f8a7ace
  

  ewencp

  authored and

  gwenshap

  committed
  f8a7ace

  Copy full SHA for f8a7ace

Commits on Jul 9, 2016

• KAFKA-3849; Add explanation on why polling every second in MirrorMaker is required

  Show description for 2dfbf4b
  

  Ashish Singh

  authored and

  ijuma

  committed
  2dfbf4b

  Copy full SHA for 2dfbf4b

• MINOR: Typo fix in comments

  Show description for a5da2a4
  

  naferx

  authored and

  ijuma

  committed
  a5da2a4

  Copy full SHA for a5da2a4

• MINOR: Update design.html

  Show description for c2459d3
  

  nihed

  authored and

  ijuma

  committed
  c2459d3

  Copy full SHA for c2459d3

• KAFKA-3844; Sort configuration items in log

  Show description for 4b5ed36
  

  rekhajoshm

  authored and

  ijuma

  committed
  4b5ed36

  Copy full SHA for 4b5ed36

Commits on Jul 8, 2016

• KAFKA-3111; Fix ConsumerPerformance reporting to use time-based instead of message-based intervals

  Show description for 0edaa89
  

  vahidhashemian

  authored and

  junrao

  committed
  0edaa89

  Copy full SHA for 0edaa89

• KAFKA-3920: Add Schema source connector to Kafka Connect

  Show description for 542350d
  

  Ishiihara

  authored and

  ewencp

  committed
  542350d

  Copy full SHA for 542350d

• KAFKA-3887: KAFKA-3817 follow-up to avoid forwarding value if it is null in KTableRepartition

  Show description for 730bf9a
  guozhangwang

  committed
  730bf9a

  Copy full SHA for 730bf9a

Commits on Jul 6, 2016

• KAFKA-3926: Fix transient test failure in RegexSourceIntegrationTest

  Show description for efc4c88
  

  bbejeck

  authored and

  guozhangwang

  committed
  efc4c88

  Copy full SHA for efc4c88

• KAFKA-3836: KStreamReduce and KTableReduce should not pass nulls to Deserializers

  Show description for 7218648
  

  jeyhunkarimov

  authored and

  guozhangwang

  committed
  7218648

  Copy full SHA for 7218648

• KAFKA-3794: added stream / table names as prefix to print / writeAsText

  Show description for b64302f
  

  bbejeck

  authored and

  guozhangwang

  committed
  b64302f

  Copy full SHA for b64302f

• KAFKA-3802; log mtimes reset on broker restart / shutdown

  Show description for 15e0087
  

  Moritz Siuts

  authored and

  ijuma

  committed
  15e0087

  Copy full SHA for 15e0087

Commits on Jul 5, 2016

• MINOR: fix generics in Windows.segments and Windows.until

  Show description for dca263b
  

  dguy

  authored and

  guozhangwang

  committed
  dca263b

  Copy full SHA for dca263b

• MINOR: Fix generics in KStream.groupBy(...)

  Show description for 416c3a7
  

  dguy

  authored and

  guozhangwang

  committed
  416c3a7

  Copy full SHA for 416c3a7

• HOTFIX: Auto-repartitioning for merge() and code simplifications

  Show description for 12fa188
  

  mjsax

  authored and

  guozhangwang

  committed
  12fa188

  Copy full SHA for 12fa188

• MINOR: Fix few documentation errors in streams quickstart

  Show description for 87b3ce1
  

  Alex Glikson

  authored and

  guozhangwang

  committed
  87b3ce1

  Copy full SHA for 87b3ce1

Commits on Jul 4, 2016

• KAFKA-3854: Fix issues with new consumer's subsequent regex (pattern) subscriptions

  Show description for d7de59a
  

  vahidhashemian

  authored and

  ewencp

  committed
  d7de59a

  Copy full SHA for d7de59a

Commits on Jul 2, 2016

• MINOR: Warning instead of error if TGT cannot be renewed beyond the next expiry date

  Show description for 31b4460
  

  Sriharsha Chintalapani

  authored and

  ijuma

  committed
  31b4460

  Copy full SHA for 31b4460

• MINOR: Typo fix in docs ops

  Show description for 0f8b679
  

  thanasis00

  authored and

  ijuma

  committed
  0f8b679

  Copy full SHA for 0f8b679

• MINOR: Fix consumer constructor doc string

  Show description for f1323d4
  

  granthenke

  authored and

  ijuma

  committed
  f1323d4

  Copy full SHA for f1323d4

• MINOR: remove "auto.commit.interval.ms" from "Manual Offset Control" example

  Show description for 32e24b7
  

  xuwei-k

  authored and

  ijuma

  committed
  32e24b7

  Copy full SHA for 32e24b7

Pagination

Previous

Next