Commits

Branch selector

 trunk

User selector

All users

Datepicker

All time

Commit History

Commits on Jan 15, 2016

• KAFKA-3108: custom StreamParitioner for Windowed key

  Show description for 37be6d9
  

  Yasuhiro Matsuda

  authored and

  guozhangwang

  committed
  37be6d9

• 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 13, 2016

• MINOR: modify config specification of topic level

  Show description for 7001174
  

  EamonZhang

  authored and

  guozhangwang

  committed
  7001174

• MINOR: Typo in documentation of topic config removal

  Show description for d61543e
  

  s7anley

  authored and

  guozhangwang

  committed
  d61543e

• KAFKA-3063; LogRecoveryTest causes JVM to exit occasionally

  Show description for 836cb19
  

  ijuma

  authored and

  ewencp

  committed
  836cb19

Commits on Jan 12, 2016

• KAFKA-3069: Fix recursion in ZkSecurityMigrator

  Show description for 72eebad
  

  fpj

  authored and

  ewencp

  committed
  72eebad

• KAFKA-3078: Add ducktape tests for KafkaLog4jAppender producing to SASL enabled Kafka cluster

  Show description for 3e5afbf
  

  Ashish Singh

  authored and

  ewencp

  committed
  3e5afbf

• KAFKA-3077: Enable KafkaLog4jAppender to work with SASL enabled brokers

  Show description for 2adeb21
  

  Ashish Singh

  authored and

  ewencp

  committed
  2adeb21

• MINOR: remove unused TimeUnit from MetricConfig

  Show description for c911448
  

  lindong28

  authored and

  guozhangwang

  committed
  c911448

Commits on Jan 11, 2016

• KAFKA-3085; BrokerChangeListener computes inconsistent live/dead broker list

  Show description for e789a35
  

  dajac

  authored and

  junrao

  committed
  e789a35

• KAFKA-3021: Centralize dependency version management

  Show description for f009c30
  

  granthenke

  authored and

  ewencp

  committed
  f009c30

• KAFKA-3019: Add an exceptionName method to Errors

  Show description for 9c998dd
  

  granthenke

  authored and

  ewencp

  committed
  9c998dd

• KAFKA-3084: Topic existence checks in topic commands (create, alter, delete)

  Show description for 3a0fc12
  

  granthenke

  authored and

  ewencp

  committed
  3a0fc12

• KAFKA-3044: Re-word consumer.poll behaviour

  Show description for 7059158
  

  praveend

  authored and

  ewencp

  committed
  7059158

Commits on Jan 9, 2016

• MINOR: Security doc fixes

  Show description for 36f5c46
  

  ijuma

  authored and

  ewencp

  committed
  36f5c46

Commits on Jan 8, 2016

• MINOR: Add property to configure showing of standard streams in Gradle

  Show description for 8d67485
  

  ijuma

  authored and

  ewencp

  committed
  8d67485

• MINOR: speed up connect startup when full connector class name is provided

  Show description for 58def1c
  

  Jason Gustafson

  authored and

  ewencp

  committed
  58def1c

• MINOR: Fix typos in Kafka website page

  Show description for ccdf552
  

  Gabriel Zhang

  authored and

  guozhangwang

  committed
  ccdf552

• KAFKA-2979: Enable authorizer and ACLs in ducktape tests

  Show description for 49778b1
  

  fpj

  authored and

  ewencp

  committed
  49778b1

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

  Show description for 40d731b
  guozhangwang

  committed
  40d731b

Commits on Jan 7, 2016

• KAFKA-2649: Add support for custom partitioning in topology sinks

  Show description for 4836e52
  

  rhauch

  authored and

  guozhangwang

  committed
  4836e52

• KAFKA-2988; Change default configuration of the log cleaner

  Show description for ee1770e
  

  granthenke

  authored and

  junrao

  committed
  ee1770e

• KAFKA-2929: Migrate duplicate error mapping functionality

  Show description for a9ff3f2
  

  granthenke

  authored and

  ewencp

  committed
  a9ff3f2

• KAFKA-3022: Deduplicate common project configurations

  Show description for 991cafe
  

  granthenke

  authored and

  ewencp

  committed
  991cafe

• KAFKA-2072; Replace StopReplica Request/Response with their org.apache.kafka.common.requests equivalents

  Show description for 00114da
  

  dajac

  authored and

  junrao

  committed
  00114da

Commits on Jan 6, 2016

• KAFKA-2874; shutdown ZK process reliably

  Show description for d9cabfd
  

  Michael G. Noll

  authored and

  junrao

  committed
  d9cabfd

• KAFKA-2850; Fix SSL invalid endpoint validation test

  Show description for 85039ab
  

  rajinisivaram

  authored and

  junrao

  committed
  85039ab

• KAFKA-3016: phase-2. stream join implementations

  Show description for 5aad499
  

  Yasuhiro Matsuda

  authored and

  guozhangwang

  committed
  5aad499

• KAFKA-2937; Disable the leaderIsr check if the topic is to be deleted.

  Show description for a788c65
  

  Mayuresh Gharat

  authored and

  junrao

  committed
  a788c65

• KAFKA-1901; Added error handling when no file exists in .git/refs/heads.

  Show description for 25fa39d
  

  omkreddy

  authored and

  guozhangwang

  committed
  25fa39d

Commits on Jan 5, 2016

• KAFKA-3058; remove the usage of deprecated config properties

  Show description for b098f67
  

  konradkalita

  authored and

  junrao

  committed
  b098f67

• KAFKA-3045; ZkNodeChangeNotificationListener shouldn't log InterruptedException as error

  Show description for c44c898
  

  lindong28

  authored and

  junrao

  committed
  c44c898

• KAFKA-3010; Include error in log when ack 0

  Show description for 5db147c
  

  ijuma

  authored and

  junrao

  committed
  5db147c

• MINOR: Update config/producer.properties to have new producer properties

  Show description for 23d607d
  

  ijuma

  authored and

  gwenshap

  committed
  23d607d

Pagination

PreviousNext