Commits

Branch selector

 trunk

User selector

All users

All time

Commit History

Commits on May 20, 2019

• KAFKA-8395: Add the ability to back up segment files on truncation

  Show description for b6f2517
  axiak

  committed
  b6f2517

  Copy full SHA for b6f2517

• KAFKA-8381; Disable hostname validation when verifying inter-broker SSL (#6757)

  Show description for 614ea55
  rajinisivaram

  authored
  614ea55

  Copy full SHA for 614ea55

• MINOR: Add log when the consumer does not send an offset commit due to not being part of an active group (#6404)

  Show description for 5a30a80
  

  stanislavkozlovski

  authored and

  hachikuji

  committed
  5a30a80

  Copy full SHA for 5a30a80

• KAFKA-8290: Close producer for zombie task (#6636)

  Show description for 11a8a8d
  bbejeck

  authored
  11a8a8d

  Copy full SHA for 11a8a8d

Commits on May 19, 2019

• MINOR: Update command options for kafka-console-consumer.sh in vagrant/README.md (#6689)

  Show description for fc616cb
  

  sekikn

  authored and

  hachikuji

  committed
  fc616cb

  Copy full SHA for fc616cb

• KAFKA-6474: remove KStreamTestDriver (#6732)

  Show description for c140f09
  

  vvcephei

  authored and

  guozhangwang

  committed
  c140f09

  Copy full SHA for c140f09

Commits on May 18, 2019

• MINOR: Increase security test timeouts for transient failures (#6760)

  Show description for b521703
  hachikuji

  authored
  b521703

  Copy full SHA for b521703

• MINOR: Fix typo in heartbeat request protocol definition (#6759)

  Show description for e00c0d3
  

  Boyang Chen

  authored and

  hachikuji

  committed
  e00c0d3

  Copy full SHA for e00c0d3

• KAFKA-8349; Add Windows batch files corresponding to kafka-delete-records.sh and kafka-log-dirs.sh (#6709)

  Show description for a29a005
  

  sekikn

  authored and

  hachikuji

  committed
  a29a005

  Copy full SHA for a29a005

• MINOR: Fixed broken link to the IBM article about j-zerocopy (#6749)

  Show description for 51c72ad
  

  commandini

  authored and

  hachikuji

  committed
  51c72ad

  Copy full SHA for 51c72ad

• KAFKA-8225 & KIP-345 part-2: fencing static member instances with conflicting group.instance.id (#6650)

  Show description for 9fa331b
  

  Boyang Chen

  authored and

  guozhangwang

  committed
  9fa331b

  Copy full SHA for 9fa331b

• KAFKA-8365; Consumer and protocol support for follower fetching (#6731)

  Show description for e2847e8
  

  mumrah

  authored and

  hachikuji

  committed
  e2847e8

  Copy full SHA for e2847e8

Commits on May 17, 2019

• MINOR: Remove spammy log message during topic deletion

  Show description for d6057a9
  

  hachikuji

  authored and

  gwenshap

  committed
  d6057a9

  Copy full SHA for d6057a9

• KAFKA-6455: Improve DSL operator timestamp semantics (#6725)

  Show description for 6a2749f
  

  mjsax

  authored and

  bbejeck

  committed
  6a2749f

  Copy full SHA for 6a2749f

• KAFKA-3522: TopologyTestDriver should only return custom stores via untyped getStateStore() method (#6756)

  Show description for e018bfe
  

  mjsax

  authored and

  bbejeck

  committed
  e018bfe

  Copy full SHA for e018bfe

• KAFKA-8346; Improve replica fetcher behavior for handling partition failure [KIP-461] (#6716)

  Show description for 414852c
  

  agg111

  authored and

  hachikuji

  committed
  414852c

  Copy full SHA for 414852c

• MINOR: Add select changes from 3rd KIP-307 PR for incrementing name index counter (#6754)

  Show description for 9077d83
  bbejeck

  authored
  9077d83

  Copy full SHA for 9077d83

• KAFKA-8215: Upgrade Rocks to v5.18.3 (#6743)

  Show description for 16769d2
  

  ableegoldman

  authored and

  bbejeck

  committed
  16769d2

  Copy full SHA for 16769d2

• MINOR: Fix race condition in Streams tests (#6748)

  Show description for a1286ed
  mjsax

  authored
  a1286ed

  Copy full SHA for a1286ed

• MINOR: Add test for ConsumerNetworkClient.trySend (#6739)

  Show description for 64c2d49
  

  lambdaliu

  authored and

  hachikuji

  committed
  64c2d49

  Copy full SHA for 64c2d49

• KAFKA-8379; Fix KafkaAdminClientTest.testUnreachableBootstrapServer (#6753)

  Show description for 8de7d37
  rajinisivaram

  authored
  8de7d37

  Copy full SHA for 8de7d37

• KAFKA-8265: Initial implementation for ConnectorClientConfigPolicy to enable overrides (KIP-458) (#6624)

  Show description for 2e91a31
  

  mageshn

  authored and

  ijuma

  committed
  2e91a31

  Copy full SHA for 2e91a31

• KAFKA-5505: Incremental cooperative rebalancing in Connect (KIP-415) (#6363)

  Show description for ce584a0
  

  kkonstantine

  authored and

  rhauch

  committed
  ce584a0

  Copy full SHA for ce584a0

Commits on May 16, 2019

• Add '?expand' query param for additional info on '/connectors'. (#6658)

  Show description for 5a95c2e
  

  norwood

  authored and

  rhauch

  committed
  5a95c2e

  Copy full SHA for 5a95c2e

• KAFKA-8376; Least loaded node should consider connections which are being prepared (#6746)

  Show description for 26814e0
  

  hachikuji

  authored and

  ijuma

  committed
  26814e0

  Copy full SHA for 26814e0

• KAFKA-8256; Replace Heartbeat request/response with automated protocol (#6691)

  Show description for 855f899
  

  mimaison

  authored and

  hachikuji

  committed
  855f899

  Copy full SHA for 855f899

• KAFAK-3522: Add TopologyTestDriver unit tests (#6179)

  Show description for 16b4088
  mjsax

  authored
  16b4088

  Copy full SHA for 16b4088

• KAFKA-8347: Choose next record to process by timestamp (#6719)

  Show description for 8078427
  

  ableegoldman

  authored and

  bbejeck

  committed
  8078427

  Copy full SHA for 8078427

• MINOR: Added missing method parameter to `performAssignment` javadoc (#6744)

  Show description for b96aa00
  

  sandmannn

  authored and

  hachikuji

  committed
  b96aa00

  Copy full SHA for b96aa00

• KAFKA-8220; Avoid kicking out static group members through rebalance timeout (#6666)

  Show description for 6e6dcce
  

  Boyang Chen

  authored and

  hachikuji

  committed
  6e6dcce

  Copy full SHA for 6e6dcce

• KAFKA-3816: Add MDC logging to Connect runtime (#5743)

  Show description for b395ef4
  

  rhauch

  authored and

  guozhangwang

  committed
  b395ef4

  Copy full SHA for b395ef4

• MINOR: Enable console logs in Connect tests (#6745)

  Show description for 2327b35
  

  kkonstantine

  authored and

  rhauch

  committed
  2327b35

  Copy full SHA for 2327b35

Commits on May 15, 2019

• KAFKA-8320 : fix retriable exception package for source connectors (#6675)

  Show description for 5928ffd
  

  mageshn

  authored and

  rhauch

  committed
  5928ffd

  Copy full SHA for 5928ffd

• KAFKA-8354; Replace Sync group request/response with automated protocol (#6729)

  Show description for 2208f99
  

  Boyang Chen

  authored and

  hachikuji

  committed
  2208f99

  Copy full SHA for 2208f99

• KAFKA-5061 - Make default Worker Task client IDs distinct (#6097)

  Show description for fbb0995
  

  pdavidson100

  authored and

  rhauch

  committed
  fbb0995

  Copy full SHA for fbb0995