Commits

Branch selector

 trunk

User selector

All users

Datepicker

All time

Commit History

Commits on Nov 6, 2015

• HOTFIX: unsubscribe does not clear user assignment properly

  Show description for b1eaa46
  

  hachikuji

  authored and

  gwenshap

  committed
  b1eaa46

  Copy full SHA for b1eaa46

• KAFKA-2490: support new consumer in ConsumerGroupCommand

  Show description for c3c0c04
  

  Ashish Singh

  authored and

  gwenshap

  committed
  c3c0c04

  Copy full SHA for c3c0c04

• KAFKA-2702: ConfigDef toHtmlTable() sorts in a way that is a bit conf…

  Show description for 33e879a
  

  granthenke

  authored and

  gwenshap

  committed
  33e879a

  Copy full SHA for 33e879a

• KAFKA-2745: Update JavaDoc for new / updated consumer APIs

  Show description for 76bcccd
  

  guozhangwang

  authored and

  gwenshap

  committed
  76bcccd

  Copy full SHA for 76bcccd

Commits on Nov 5, 2015

• KAFKA-2756: Use request version Id instead of latest version Id to parse the corresponding response.

  Show description for cbdd821
  

  Matthew Bruce

  authored and

  guozhangwang

  committed
  cbdd821

  Copy full SHA for cbdd821

• MINOR: follow-up KAFKA-2730 to use two tags for broker id and fetcher id combination

  Show description for 0273c43
  guozhangwang

  committed
  0273c43

  Copy full SHA for 0273c43

• KAFKA-2735: BrokerEndPoint should support uppercase hostnames.

  Show description for bf2563e
  

  jholoman

  authored and

  guozhangwang

  committed
  bf2563e

  Copy full SHA for bf2563e

• KAFKA-2755: Suspicious reference forwarding cause NPE on handleDescribeGroup.

  Show description for 490bbc9
  

  Ashish Singh

  authored and

  guozhangwang

  committed
  490bbc9

  Copy full SHA for 490bbc9

• KAFKA-2753: improve SyncGroup error handling in client

  Show description for 7eee114
  

  hachikuji

  authored and

  guozhangwang

  committed
  7eee114

  Copy full SHA for 7eee114

• KAFKA-2748: Ensure sink tasks commit offsets upon rebalance and rewind if the SinkTask flush fails.

  Show description for a455177
  

  ewencp

  authored and

  guozhangwang

  committed
  a455177

  Copy full SHA for a455177

• KAFKA-2738: Replica FetcherThread should connect to leader endpoint matching its inter-broker security protocol.

  Show description for d23785f
  

  gwenshap

  authored and

  guozhangwang

  committed
  d23785f

  Copy full SHA for d23785f

• KAFKA-2743: Make forwarded task reconfiguration requests asynchronous on backoff on retrying.

  Show description for b30d68a
  

  ewencp

  authored and

  guozhangwang

  committed
  b30d68a

  Copy full SHA for b30d68a

• KAFKA-2741: Make SourceTaskContext and SinkTaskContext interfaces and keep implementations in runtime jar.

  Show description for 7d6515f
  

  ewencp

  authored and

  guozhangwang

  committed
  7d6515f

  Copy full SHA for 7d6515f

• KAFKA-2742: Fix SourceTaskOffsetCommitter to handle removal of commit tasks when they are already in progress.

  Show description for 4a9e760
  

  ewencp

  authored and

  guozhangwang

  committed
  4a9e760

  Copy full SHA for 4a9e760

• MINOR: add test case for fetching from a compacted topic

  Show description for 68f4221
  

  hachikuji

  authored and

  guozhangwang

  committed
  68f4221

  Copy full SHA for 68f4221

Commits on Nov 4, 2015

• KAFKA-2697: client-side support for leave group

  Show description for ef5d168
  

  hachikuji

  authored and

  guozhangwang

  committed
  ef5d168

  Copy full SHA for ef5d168

• HOTFIX: Fix incorrect version used for group metadata version

  Show description for 8de6225
  

  hachikuji

  authored and

  guozhangwang

  committed
  8de6225

  Copy full SHA for 8de6225

• KAFKA-2744: Commit source task offsets after task is completely stopped

  Show description for 70a784b
  

  ewencp

  authored and

  guozhangwang

  committed
  70a784b

  Copy full SHA for 70a784b

• KAFKA-2691: Improve handling of authorization failure during metadata refresh

  Show description for c39e79b
  

  hachikuji

  authored and

  gwenshap

  committed
  c39e79b

  Copy full SHA for c39e79b

• KAFKA-2730: use thread-id as metrics tags

  Show description for c30ee50
  

  guozhangwang

  authored and

  gwenshap

  committed
  c30ee50

  Copy full SHA for c30ee50

• KAFKA-2737: Added single- and multi-consumer integration tests for round-robin assignment

  Show description for aa73554
  

  apovzner

  authored and

  guozhangwang

  committed
  aa73554

  Copy full SHA for aa73554

• KAFKA-2727: Topology partial construction

  Show description for 421de0a
  

  Yasuhiro Matsuda

  authored and

  guozhangwang

  committed
  421de0a

  Copy full SHA for 421de0a

• KAFKA-2740: Convert Windows bin scripts from CRLF to LF line encodings

  Show description for 7ded64b
  

  Michael G. Noll

  authored and

  guozhangwang

  committed
  7ded64b

  Copy full SHA for 7ded64b

• KAFKA-2722; Improve ISR change propagation.

  Show description for 70a7d57
  

  becketqin

  authored and

  junrao

  committed
  70a7d57

  Copy full SHA for 70a7d57

• KAFKA-2644; Run relevant ducktape tests with SASL_PLAINTEXT and SASL_SSL

  Show description for 98db5ea
  

  rajinisivaram

  authored and

  junrao

  committed
  98db5ea

  Copy full SHA for 98db5ea

Commits on Nov 3, 2015

• KAFKA-2687: Add support for ListGroups and DescribeGroup APIs

  Show description for 596c203
  

  hachikuji

  authored and

  guozhangwang

  committed
  596c203

  Copy full SHA for 596c203

• KAFKA-2441: SSL/TLS in official docs

  Show description for f413143
  

  gwenshap

  authored and

  guozhangwang

  committed
  f413143

  Copy full SHA for f413143

• KAFKA-2480: Add backoff timeout and support rewinds

  Show description for 5aa5f19
  

  Ishiihara

  authored and

  gwenshap

  committed
  5aa5f19

  Copy full SHA for 5aa5f19

• KAFKA-2716: Make Kafka core not depend on log4j-appender

  Show description for edddc41
  

  Ashish Singh

  authored and

  gwenshap

  committed
  edddc41

  Copy full SHA for edddc41

• KAFKA-2724: ZK Auth documentation.

  Show description for 840e958
  

  fpj

  authored and

  gwenshap

  committed
  840e958

  Copy full SHA for 840e958

• KAFKA-2719; Use wildcard classpath for dependant-libs

  Show description for 694e03c
  

  rajinisivaram

  authored and

  junrao

  committed
  694e03c

  Copy full SHA for 694e03c

• KAFKA-2017: Persist Group Metadata and Assignment before Responding

  Show description for 7c33475
  guozhangwang

  committed
  7c33475

  Copy full SHA for 7c33475

Commits on Nov 2, 2015

• KAFKA-2707: make KStream processor names deterministic

  Show description for e466ccd
  

  Yasuhiro Matsuda

  authored and

  guozhangwang

  committed
  e466ccd

  Copy full SHA for e466ccd

• KAFKA-2726: Fix port collision between ntpdate and ntp daemon

  Show description for 1f5d05f
  

  Geoff Anderson

  authored and

  guozhangwang

  committed
  1f5d05f

  Copy full SHA for 1f5d05f

• KAFKA-2706: make state stores first class citizens in the processor topology

  Show description for 7582722
  

  Yasuhiro Matsuda

  authored and

  guozhangwang

  committed
  7582722

  Copy full SHA for 7582722

Pagination

Previous

Next