Commits

Branch selector

 trunk

User selector

guozhangwang

Datepicker

All time

Commit History

Commits on Jan 15, 2016

• MINOR: add internal source topic for tracking

  Show description for a3d3d53
  guozhangwang

  committed
  a3d3d53

Commits on Jan 14, 2016

• KAFKA-3081: KTable Aggregation

  Show description for 4f22705
  guozhangwang

  committed
  4f22705

Commits on Jan 8, 2016

• KAFKA-2653: Add KStream/KTable Aggregation and KTable Join APIs

  Show description for 40d731b
  guozhangwang

  committed
  40d731b

Commits on Dec 15, 2015

• KAFKA-2837 Follow-up: Default max block to 60 seconds

  Show description for 901fe2e
  guozhangwang

  committed
  901fe2e

Commits on Dec 10, 2015

• KAFKA-2733: Standardize metric name for Kafka Streams

  Show description for ec466d3
  guozhangwang

  committed
  ec466d3

Commits on Dec 7, 2015

• KAFKA-2804: manage changelog topics through ZK in PartitionAssignor

  Show description for d05fa0a
  

  guozhangwang

  authored and

  gwenshap

  committed
  d05fa0a

Commits on Nov 25, 2015

• MINOR: Support GitHub OAuth tokens in kafka-merge-pr.py

  Show description for 34a6be2
  

  guozhangwang

  authored and

  gwenshap

  committed
  34a6be2

• KAFKA-2881: Improve Consumer Configs and API Documentation

  Show description for 395bf46
  

  guozhangwang

  authored and

  gwenshap

  committed
  395bf46

Commits on Nov 18, 2015

• MINOR: fix shutdownHook in ConsoleConsumer

  Show description for 36b1c1d
  

  guozhangwang

  authored and

  junrao

  committed
  36b1c1d

Commits on Nov 13, 2015

• KAFKA-2833; print only group offset / metadata according to the formatter

  Show description for 43ef015
  

  guozhangwang

  authored and

  junrao

  committed
  43ef015

• KAFKA-2819; catch NoSuchElementException in ConsoleConsumer

  Show description for 4170847
  

  guozhangwang

  authored and

  junrao

  committed
  4170847

Commits on Nov 11, 2015

• KAFKA-2770: Catch and ignore WakeupException for commit upon closing

  Show description for e0098b4
  guozhangwang

  committed
  e0098b4

Commits on Nov 10, 2015

• KAFKA-2799: skip wakeup in the follow-up poll() call.

  Show description for 9d9bb70
  guozhangwang

  committed
  9d9bb70

Commits on Nov 9, 2015

• MINOR: remove old producer in config sections to align with APIs

  Show description for a87b978
  

  guozhangwang

  authored and

  gwenshap

  committed
  a87b978

Commits on Nov 7, 2015

• KAFKA-2766: use new producer by default in tooling

  Show description for 15524d0
  

  guozhangwang

  authored and

  gwenshap

  committed
  15524d0

Commits on Nov 6, 2015

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

  Show description for 76bcccd
  

  guozhangwang

  authored and

  gwenshap

  committed
  76bcccd

Commits on Nov 5, 2015

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

  Show description for 0273c43
  guozhangwang

  committed
  0273c43

Commits on Nov 4, 2015

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

  Show description for c30ee50
  

  guozhangwang

  authored and

  gwenshap

  committed
  c30ee50

Commits on Nov 3, 2015

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

  Show description for 7c33475
  guozhangwang

  committed
  7c33475

Commits on Oct 28, 2015

• MINOR: Clean-up MemoryRecords variables and APIs

  Show description for b6fe164
  guozhangwang

  committed
  b6fe164

• HOTFIX: Rename WakeupException in MirrorMaker

  Show description for 80223ba
  guozhangwang

  committed
  80223ba

Commits on Oct 23, 2015

• KAFKA-2686: Reset needsPartitionAssignment in SubscriptionState.assign()

  Show description for aa56dfb
  guozhangwang

  committed
  aa56dfb

Commits on Oct 20, 2015

• HOTFIX: check logic of KAFKA-2515 should be on buffer.limit()

  Show description for 8f32617
  guozhangwang

  committed
  8f32617

Commits on Oct 17, 2015

• KAFKA-2515: Handle oversized messages properly in new consumer

  Show description for e2e5c89
  guozhangwang

  committed
  e2e5c89

Commits on Oct 14, 2015

• TRIVIAL: add @throws ConsumerWakeupException in KafkaConsumer

  Show description for 28e59a1
  

  guozhangwang

  authored and

  gwenshap

  committed
  28e59a1

• KAFKA-2632: move fetchable check ahead in handleFetchResponse

  Show description for d8c5750
  

  guozhangwang

  authored and

  gwenshap

  committed
  d8c5750

Commits on Oct 5, 2015

• TRIVIAL: remove TODO in KafkaConsumer after KAFKA-2120

  Show description for 726e23e
  guozhangwang

  committed
  726e23e

• HOTFIX: Persistent store in ProcessorStateManagerTest

  Show description for f236bc2
  guozhangwang

  committed
  f236bc2

Commits on Oct 3, 2015

• KAFKA-2591: Fix StreamingMetrics

  Show description for 37f7d75
  guozhangwang

  committed
  37f7d75

Commits on Sep 26, 2015

• KIP-28: Add a processor client for Kafka Streaming

  Show description for 263c10a
  guozhangwang

  committed
  263c10a

Commits on Jul 24, 2015

• KAFKA-2353; SocketServer catch exception and close connection properly; reviewed by Gwen Shapira, Ismael Juma and Guozhang Wang

  guozhangwang

  committed
  520a813

Commits on Jul 2, 2015

• KAFKA-1740: merge offset manager into consumer coordinator; reviewed by Onur Karaman and Jason Gustafson

  guozhangwang

  committed
  3f8480c

Commits on Jun 10, 2015

• KAFKA-2253; fix deadlock between removeWatchersLock and watcher operations list lock; reviewed by Onur Karaman and Jiangjie Qin

  guozhangwang

  committed
  9f80665

Commits on Jun 3, 2015

• KAFKA-2208; add consumer side error handling upon coordinator failure; reviewed by Onur Karaman

  guozhangwang

  committed
  d22987f

Commits on May 20, 2015

• KAFKA-2160; remove watcher list if empty in purgatory; remove join-group purgatory in coordinator; reviewed by Jun Rao

  guozhangwang

  committed
  0ad6466

Pagination

PreviousNext