Commits

Branch selector

 trunk

User selector

All users

All time

Commit History

Commits on Jul 22, 2017

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

  Show description for 91b5fc7
  ijuma

  committed
  91b5fc7

  Copy full SHA for 91b5fc7

• MINOR: Improve log warning to include the log name

  Show description for 7727d7a
  ijuma

  committed
  7727d7a

  Copy full SHA for 7727d7a

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

  Show description for c71e7fa
  ewencp

  committed
  c71e7fa

  Copy full SHA for c71e7fa

• MINOR: Add Streams landing page

  Show description for 300f480
  

  derrickdoo

  authored and

  guozhangwang

  committed
  300f480

  Copy full SHA for 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

  Copy full SHA for 6c6cf01

• MINOR: Added safe deserialization implementation

  Show description for da42977
  

  Hooman Broujerdi

  authored and

  ewencp

  committed
  da42977

  Copy full SHA for da42977

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

  Show description for 4a7064d
  

  rosets

  authored and

  hachikuji

  committed
  4a7064d

  Copy full SHA for 4a7064d

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

  Show description for 08b775c
  ijuma

  committed
  08b775c

  Copy full SHA for 08b775c

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

  Show description for 1110f66
  dguy

  committed
  1110f66

  Copy full SHA for 1110f66

• MINOR: Make Kafka Connect step in quickstart more Windows friendly

  Show description for beb0ad9
  

  vahidhashemian

  authored and

  ewencp

  committed
  beb0ad9

  Copy full SHA for beb0ad9

• KAFKA-5468: WorkerSourceTask offset commit loglevel changes

  Show description for ad6c53d
  

  Stephane Maarek

  authored and

  ewencp

  committed
  ad6c53d

  Copy full SHA for ad6c53d

• KAFKA-5431; cleanSegments should not set length for cleanable segment files

  Show description for cd207dd
  

  huxihx

  authored and

  junrao

  committed
  cd207dd

  Copy full SHA for cd207dd

• MINOR: Fixed misleading reference to HTTPS instead of SSL support in the doc

  Show description for 1d2d0ba
  

  ppatierno

  authored and

  ewencp

  committed
  1d2d0ba

  Copy full SHA for 1d2d0ba

• KAFKA-5410; Fix taskClass() method name in Connector and flush() signature in SinkTask

  Show description for 8a81566
  

  ppatierno

  authored and

  ewencp

  committed
  8a81566

  Copy full SHA for 8a81566

• KAFKA-5623: ducktape kafka service: do not assume Service contains num_nodes

  Show description for 9ae09e8
  

  cmccabe

  authored and

  ewencp

  committed
  9ae09e8

  Copy full SHA for 9ae09e8

• KAFKA-5534; KafkaConsumer `offsetForTimes` result should include partitions with no offset

  Show description for 5bb53e0
  

  vahidhashemian

  authored and

  hachikuji

  committed
  5bb53e0

  Copy full SHA for 5bb53e0

Commits on Jul 20, 2017

• KAFKA-5610; WriteTxnMarker handler should return UNKNOWN_TOPIC_OR_PARTITION if replica is not available

  Show description for cdff011
  

  Apurva Mehta

  authored and

  hachikuji

  committed
  cdff011

  Copy full SHA for cdff011

• MINOR: Apply extra serialized rsync step to both parallel and serial paths

  Show description for 9b7a6ee
  ewencp

  committed
  9b7a6ee

  Copy full SHA for 9b7a6ee

• KAFKA-3856; Cleanup Kafka Stream builder API (KIP-120)

  Show description for b04bed0
  

  mjsax

  authored and

  dguy

  committed
  b04bed0

  Copy full SHA for b04bed0

• KAFKA-5556; Fix IllegalStateException in KafkaConsumer.commitSync due to missing future completion check

  Show description for e0099e1
  

  umesh9794

  authored and

  hachikuji

  committed
  e0099e1

  Copy full SHA for e0099e1

• KAFKA-4830; Augment KStream.print() to allow users pass in extra parameters in the printed string

  Show description for fe4a469
  

  jameschien

  authored and

  dguy

  committed
  fe4a469

  Copy full SHA for fe4a469

• MINOR: Simplify SensorAccess usage

  Show description for 84d2b6a
  ijuma

  committed
  84d2b6a

  Copy full SHA for 84d2b6a

• KAFKA-5134; Replace zkClient.getChildren method with zkUtils.getChildren

  Show description for 272956f
  

  baluchicken

  authored and

  ijuma

  committed
  272956f

  Copy full SHA for 272956f

• MINOR: Docs update, Java clients use Kafka Metrics

  Show description for 0816e47
  

  jklukas

  authored and

  ijuma

  committed
  0816e47

  Copy full SHA for 0816e47

• MINOR: Implement ConfigEntry.toString()

  Show description for 1b8aed6
  

  ppatierno

  authored and

  ijuma

  committed
  1b8aed6

  Copy full SHA for 1b8aed6

• MINOR: Clarify wording in server.properties comment

  Show description for 43aa14f
  

  jeffwidman

  authored and

  ijuma

  committed
  43aa14f

  Copy full SHA for 43aa14f

• KAFKA-5608: Add --wait option for JmxTool and use in system tests to avoid race between JmxTool and monitored services

  Show description for f50af9c
  ewencp

  committed
  f50af9c

  Copy full SHA for f50af9c

Commits on Jul 19, 2017

• MINOR: Code Cleanup

  Show description for f87d58b
  

  vahidhashemian

  authored and

  hachikuji

  committed
  f87d58b

  Copy full SHA for f87d58b

• MINOR: Make 'Topic-Level Configs' a doc section for easier access

  Show description for 3bfc073
  

  vahidhashemian

  authored and

  ijuma

  committed
  3bfc073

  Copy full SHA for 3bfc073

Commits on Jul 18, 2017

• MINOR: Add another common error case for CorruptRecordException's error message

  Show description for fc0ea25
  ewencp

  committed
  fc0ea25

  Copy full SHA for fc0ea25

• KAFKA-5384: Enable topic deletion by default

  Show description for ea8845b
  gwenshap

  committed
  ea8845b

  Copy full SHA for ea8845b

• MINOR: Use static imports in KafkaLog4jAppender

  Show description for bbc3900
  

  kamalcph

  authored and

  ijuma

  committed
  bbc3900

  Copy full SHA for bbc3900

• MINOR: Remove flaky assertion in verifyCloseOldestConnectionWithStagedReceives

  Show description for 454f0f1
  ijuma

  committed
  454f0f1

  Copy full SHA for 454f0f1

• MINOR: Do not wait for first line of console consumer output since we now have a more reliable test using JMX

  Show description for d663005
  ewencp

  committed
  d663005

  Copy full SHA for d663005

Commits on Jul 17, 2017

• KAFKA-5587; Remove channel only after staged receives are delivered

  Show description for 28c83d9
  

  rajinisivaram

  authored and

  ijuma

  committed
  28c83d9

  Copy full SHA for 28c83d9