Commits

Branch selector

 trunk

User selector

All users

All time

Commit History

Commits on Dec 22, 2016

• MINOR: Improve output format of `kafka_reassign_partitions.sh` tool

  Show description for 8ff5a9f
  

  vahidhashemian

  authored and

  guozhangwang

  committed
  8ff5a9f

  Copy full SHA for 8ff5a9f

Commits on Dec 21, 2016

• MINOR: Fix document header/footer links

  Show description for 7599d5d
  

  gwenshap

  authored and

  guozhangwang

  committed
  7599d5d

  Copy full SHA for 7599d5d

• MINOR: trivial logCleanerEnable doc cleanup

  Show description for 3c1df09
  

  omkreddy

  authored and

  guozhangwang

  committed
  3c1df09

  Copy full SHA for 3c1df09

• MINOR: fixup typo in ops.html

  Show description for 05d7664
  

  smferguson

  authored and

  guozhangwang

  committed
  05d7664

  Copy full SHA for 05d7664

• MINOR: KStream JavaDoc fix

  Show description for baab43f
  

  mjsax

  authored and

  guozhangwang

  committed
  baab43f

  Copy full SHA for baab43f

• KAFKA-4485; Follower should be in the isr if its FetchRequest has fetched up to the logEndOffset of leader

  Show description for fc88bac
  

  lindong28

  authored and

  junrao

  committed
  fc88bac

  Copy full SHA for fc88bac

• MINOR: Clarify log deletion configuration options in server.properties

  Show description for ecc0fc4
  

  MarkRose

  authored and

  guozhangwang

  committed
  ecc0fc4

  Copy full SHA for ecc0fc4

• MINOR: Replace TopicAndPartition with TopicPartition in `Log` and `ReplicaManager`

  Show description for 68f204e
  

  ijuma

  authored and

  hachikuji

  committed
  68f204e

  Copy full SHA for 68f204e

• MINOR: Support auto-incrementing offsets in MemoryRecordsBuilder

  Show description for 0f86dbe
  

  hachikuji

  authored and

  ijuma

  committed
  0f86dbe

  Copy full SHA for 0f86dbe

Commits on Dec 20, 2016

• KAFKA-4554; Fix ReplicaBuffer.verifyChecksum to use iterators instead of iterables

  Show description for 3930dd7
  

  ijuma

  authored and

  hachikuji

  committed
  3930dd7

  Copy full SHA for 3930dd7

• MINOR: Add more exception information in ProcessorStateManager

  Show description for 7f4b278
  guozhangwang

  committed
  7f4b278

  Copy full SHA for 7f4b278

• KAFKA-4540: Suspended tasks that are not assigned to the StreamThread need to be closed before new active and standby tasks are created

  Show description for 56c6174
  

  dguy

  authored and

  guozhangwang

  committed
  56c6174

  Copy full SHA for 56c6174

• KAFKA-4473: RecordCollector should handle retriable exceptions more strictly

  Show description for 0321bf5
  

  dguy

  authored and

  guozhangwang

  committed
  0321bf5

  Copy full SHA for 0321bf5

• KAFKA-4500; Code quality improvements

  Show description for a5c15ba
  

  rekhajoshm

  authored and

  ijuma

  committed
  a5c15ba

  Copy full SHA for a5c15ba

• MINOR: Remove incomplete gradle wrapper infrastructure

  Show description for 1358602
  

  kamilszymanski

  authored and

  ijuma

  committed
  1358602

  Copy full SHA for 1358602

• KAFKA-4447; Controller resigned but it also acts as a controller for a long time

  Show description for a786be9
  

  xiguantiaozhan

  authored and

  becketqin

  committed
  a786be9

  Copy full SHA for a786be9

• MINOR: Fix exception handling in case of file record truncation during write

  Show description for 8b84d14
  

  kamilszymanski

  authored and

  ijuma

  committed
  8b84d14

  Copy full SHA for 8b84d14

Commits on Dec 19, 2016

• KAFKA-4526; Disable throttling test until it can be fixed correctly.

  Show description for 8dbdc90
  

  apurvam

  authored and

  ijuma

  committed
  8dbdc90

  Copy full SHA for 8dbdc90

• KAFKA-4166; Fix transient MM failure caused by slow old consumer shutdown

  Show description for 529ca32
  

  hachikuji

  authored and

  ijuma

  committed
  529ca32

  Copy full SHA for 529ca32

• KAFKA-4553; Improve round robin assignment in Connect to avoid uneven distributions of connectors and tasks

  Show description for bc9ef71
  

  ewencp

  authored and

  hachikuji

  committed
  bc9ef71

  Copy full SHA for bc9ef71

• KAFKA-4534: StreamPartitionAssignor only ever updates the partitionsByHostState and metadataWithInternalTopics on first assignment

  Show description for 65acff3
  

  dguy

  authored and

  guozhangwang

  committed
  65acff3

  Copy full SHA for 65acff3

Commits on Dec 17, 2016

• KAFKA-3600; Use ApiVersions to check if broker supports required api versions

  Show description for d6b0b52
  

  Ashish Singh

  authored and

  ijuma

  committed
  d6b0b52

  Copy full SHA for d6b0b52

Commits on Dec 16, 2016

• KAFKA-4552; README.md has org.gradle.project.maxParallelForms instead of maxParallelForks

  Show description for e156f51
  

  cmccabe

  authored and

  ijuma

  committed
  e156f51

  Copy full SHA for e156f51

• MINOR: Replace deepIterator/shallowIterator with deepEntries/shallowEntries

  Show description for b58b6a1
  

  ijuma

  authored and

  hachikuji

  committed
  b58b6a1

  Copy full SHA for b58b6a1

• MINOR: Fix typo on introduction page

  Show description for e55205b
  

  ashishg-qburst

  authored and

  guozhangwang

  committed
  e55205b

  Copy full SHA for e55205b

• KAFKA-4539: StreamThread is not correctly creating StandbyTasks

  Show description for 056ed86
  

  dguy

  authored and

  guozhangwang

  committed
  056ed86

  Copy full SHA for 056ed86

• KAFKA-4537: StreamPartitionAssignor incorrectly adds standby partitions to the partitionsByHostState map

  Show description for 233cd4b
  

  dguy

  authored and

  guozhangwang

  committed
  233cd4b

  Copy full SHA for 233cd4b

Commits on Dec 15, 2016

• MINOR: update KStream JavaDocs

  Show description for c2cfadf
  

  mjsax

  authored and

  guozhangwang

  committed
  c2cfadf

  Copy full SHA for c2cfadf

• KAFKA-4451; Fix OffsetIndex overflow when replicating a highly compacted topic. OffsetIndex provides checks for overflow, used when deciding to roll a LogSegment

  Show description for e36e807
  

  michaelschiff

  authored and

  junrao

  committed
  e36e807

  Copy full SHA for e36e807

• KAFKA-4521; MirrorMaker should flush all messages before releasing partition ownership during rebalance

  Show description for 908b6d1
  

  lindong28

  authored and

  becketqin

  committed
  908b6d1

  Copy full SHA for 908b6d1

• KAFKA-4529; LogCleaner should not delete the tombstone too early.

  Show description for a9687bc
  

  becketqin

  authored and

  junrao

  committed
  a9687bc

  Copy full SHA for a9687bc

• HOTFIX: Streams fix state transition stuck on rebalance

  Show description for ea72449
  

  enothereska

  authored and

  guozhangwang

  committed
  ea72449

  Copy full SHA for ea72449

Commits on Dec 14, 2016

• MINOR: Reenable streams smoke test

  Show description for 7049938
  

  enothereska

  authored and

  guozhangwang

  committed
  7049938

  Copy full SHA for 7049938

• Separate Streams documentation and setup docs with easy to set variables

  Show description for 5342869
  

  derrickdoo

  authored and

  guozhangwang

  committed
  5342869

  Copy full SHA for 5342869

Commits on Dec 13, 2016

• KAFKA-4532: StateStores can be connected to the wrong source topic resulting in incorrect metadata returned from Interactive Queries

  Show description for 448f194
  

  dguy

  authored and

  guozhangwang

  committed
  448f194

  Copy full SHA for 448f194