Commits

Branch selector

 trunk

User selector

All users

Datepicker

All time

Commit History

Commits on Nov 16, 2017

• KAFKA-6218: Optimize condition in if statement to reduce the number of comparisons

  Show description for 0026121
  

  sachinbhalekar

  authored and

  ewencp

  committed
  0026121

• KAFKA-5811; Add Kibosh integration for Trogdor and Ducktape

  Show description for d9cbc6b
  

  cmccabe

  authored and

  rajinisivaram

  committed
  d9cbc6b

• KAFKA-5925: Adding records deletion operation to the new Admin Client API

  Show description for 53c5ccb
  

  ppatierno

  authored and

  guozhangwang

  committed
  53c5ccb

• KAFKA-6167: Timestamp on streams directory contains a colon, which is an illegal character

  Show description for 539c4d5
  

  mjsax

  authored and

  guozhangwang

  committed
  539c4d5

• MINOR: Updated KafkaZkClient.pathExists() to use ExistsRequest

  Show description for 9eabcc2
  

  mimaison

  authored and

  ijuma

  committed
  9eabcc2

• KAFKA-6210; IllegalArgumentException if 1.0.0 is used for inter.broker.protocol.version or log.message.format.version

  Show description for cdcbd92
  ijuma

  committed
  cdcbd92

Commits on Nov 15, 2017

• MINOR: Adding secondary nav to Streams webpage

  Show description for ca7f3da
  

  Manjula K

  authored and

  guozhangwang

  committed
  ca7f3da

• MINOR: Not enough replica exception should never happen for delete records

  Show description for dc2322a
  guozhangwang

  committed
  dc2322a

• MINOR: kafka-site introduction section improvements

  Show description for 48f5f04
  

  joel-hamill

  authored and

  guozhangwang

  committed
  48f5f04

• MINOR: Make PushHttpMetricsReporter API compatible with releases back to 0.8.2.2

  Show description for 54371e6
  ewencp

  committed
  54371e6

• KAFKA-6215: fix transient failures in KafkaStreamsTest

  Show description for 1756a22
  

  mjsax

  authored and

  guozhangwang

  committed
  1756a22

• MINOR: Use match instead of if/else in KafkaZkClient

  Show description for f300480
  

  mimaison

  authored and

  ijuma

  committed
  f300480

• MINOR: Handle error metrics removal during shutdown

  Show description for 3cfbb25
  rajinisivaram

  committed
  3cfbb25

Commits on Nov 10, 2017

• MINOR: Exclude Committer Checklist section from commit message

  Show description for d04daf5
  ijuma

  committed
  d04daf5

• MINOR: Exclude PULL_REQUEST_TEMPLATE.md from rat checks

  Show description for 50a44ee
  ijuma

  committed
  50a44ee

• MINOR: Use Scala Future in CoreUtils test

  Show description for b9039bb
  ijuma

  committed
  b9039bb

• MINOR: Add pull request template

  Show description for 14e3ed0
  ijuma

  committed
  14e3ed0

• HOTFIX: GlobalStateManagerImpl in trunk has renamed the consumer field

  guozhangwang

  committed
  84ddff6

• KAFKA-6175; AbstractIndex should cache index file to avoid unnecessary disk access during resize()

  Show description for 12af521
  

  lindong28

  authored and

  becketqin

  committed
  12af521

Commits on Nov 9, 2017

• KAFKA-6190: Use consumer.position() instead of record.offset() to advance in GlobalKTable restoration to avoid transactional control messages

  Show description for 66cab2f
  

  Alex Good

  authored and

  guozhangwang

  committed
  66cab2f

• MINOR: make controller helper methods private

  Show description for 564d7b3
  onurkaraman

  committed
  564d7b3

• MINOR: Update to Scala 2.11.12 (part 2)

  Show description for 3e86161
  ijuma

  committed
  3e86161

• MINOR: Remove FanoutIntegrationTest.java

  Show description for e23de3c
  guozhangwang

  committed
  e23de3c

• MINOR: Add HttpMetricsReporter for system tests

  Show description for 718dda1
  ewencp

  committed
  718dda1

• KAFKA-6185; Remove channels from explictlyMutedChannels set when closed

  Show description for 0653a89
  

  rajinisivaram

  authored and

  ijuma

  committed
  0653a89

• KAFKA-6164; Shutdown quota managers if other components fail to start

  Show description for fe31718
  

  rajinisivaram

  authored and

  ijuma

  committed
  fe31718

• MINOR: Update Scala 2.11 to 2.11.12

  Show description for 4a55818
  ijuma

  committed
  4a55818

• KAFKA-6146; minimize the number of triggers enqueuing PreferredReplicaLeaderElection events

  Show description for fef80c8
  

  onurkaraman

  authored and

  ijuma

  committed
  fef80c8

Commits on Nov 8, 2017

• KAFKA-6179: Clear min timestamp tracker upon partition queue cleanup

  Show description for ee1aaa0
  guozhangwang

  committed
  ee1aaa0

• KAFKA-5645; Use async ZookeeperClient in SimpleAclAuthorizer

  Show description for 9b44c3e
  

  omkreddy

  authored and

  junrao

  committed
  9b44c3e

Commits on Nov 7, 2017

• MINOR: Eliminate unnecessary Topic(And)Partition allocations in Controller

  Show description for 3735a6c
  ijuma

  committed
  3735a6c

• KAFKA-5894; add the notion of max inflight requests to async ZooKeeperClient

  Show description for 5813812
  onurkaraman

  committed
  5813812

Commits on Nov 6, 2017

• MINOR: PartitionReassignmentHandler should only generate event when znode is created

  Show description for 6f96d7f
  ijuma

  committed
  6f96d7f

• KAFKA-6120: RecordCollector should not retry sending

  Show description for 2b5a213
  

  mjsax

  authored and

  guozhangwang

  committed
  2b5a213

• KAFKA-6115: TaskManager should be type aware

  Show description for d637ad0
  

  mjsax

  authored and

  guozhangwang

  committed
  d637ad0

Pagination

PreviousNext