Commits

Branch selector

 temp-8436

User selector

All users

All time

Commit History

Commits on Apr 9, 2020

• Merge branch 'trunk' into temp-8436

  

  John Roesler

  committed
  872694b

  Copy full SHA for 872694b

• KAFKA-6145: KIP-441: fix flaky shouldEnforceRebalance test in StreamThreadTest (#8452)

  Show description for 0470e2b
  ableegoldman

  authored
  0470e2b

  Copy full SHA for 0470e2b

• KAFKA-9309: Add the ability to translate Message classes to and from JSON (#7844)

  Show description for bf6dffe
  cmccabe

  authored
  bf6dffe

  Copy full SHA for bf6dffe

• KAFKA-9748: Extend Streams integration tests for EOS beta (#8441)

  Show description for 73ec730
  mjsax

  authored
  73ec730

  Copy full SHA for 73ec730

• KAFKA-9642: Change "BigDecimal(double)" constructor to "BigDecimal.valueOf(double)" (#8212)

  Show description for 179be72
  SoontaekLim

  authored
  179be72

  Copy full SHA for 179be72

• KAFKA-9691: Fix NPE by waiting for reassignment request (#8317)

  Show description for 371ad14
  tombentley

  authored
  371ad14

  Copy full SHA for 371ad14

• KAFKA-9433: Use automated protocol for AlterConfigs request and response (#8315)

  Show description for c84e6ab
  tombentley

  authored
  c84e6ab

  Copy full SHA for c84e6ab

• KAFKA-9583; Use topic-partitions grouped by node to send OffsetsForLeaderEpoch requests (#8077)

  Show description for 0fad944
  andyfangdz

  authored
  0fad944

  Copy full SHA for 0fad944

• add guard

  ableegoldman

  committed
  1f0a36b

  Copy full SHA for 1f0a36b

• remove import that snuck in again >:(

  ableegoldman

  committed
  4dd64a4

  Copy full SHA for 4dd64a4

• fix test broken by rebase

  ableegoldman

  committed
  bf809a7

  Copy full SHA for bf809a7

• rebased

  ableegoldman

  committed
  24983a8

  Copy full SHA for 24983a8

• KAFKA-6145: KIP-441 Move tasks with caught-up destination clients right away (#8425)

  Show description for ed3a715
  ableegoldman

  authored
  ed3a715

  Copy full SHA for ed3a715

Commits on Apr 8, 2020

• KAFKA-9835; Protect `FileRecords.slice` from concurrent write (#8451)

  Show description for 778b1e3
  hachikuji

  authored
  778b1e3

  Copy full SHA for 778b1e3

• KAFKA-6145: KIP-441 Pt. 6 Trigger probing rebalances until group is stable (#8409)

  Show description for 98ea773
  ableegoldman

  authored
  98ea773

  Copy full SHA for 98ea773

• KAFKA-8890: Make SSL context/engine configuration extensible (KIP-519) (#8338)

  maulin-vasavada

  authored
  9ba49b8

  Copy full SHA for 9ba49b8

• HOTFIX: exclude ConsumerCoordinator from NPathComplexity check (#8447)

  Show description for 833dc77
  chia7712

  authored
  833dc77

  Copy full SHA for 833dc77

• KAFKA-9801: Still trigger rebalance when static member joins in CompletingRebalance phase (#8405)

  Show description for 94ef25a
  guozhangwang

  committed
  94ef25a

  Copy full SHA for 94ef25a

Commits on Apr 7, 2020

• KAFKA-8107; Flaky Test kafka.api.ClientIdQuotaTest.testQuotaOverrideDelete (#8394)

  Show description for 4c9f5cf
  dajac

  authored
  4c9f5cf

  Copy full SHA for 4c9f5cf

• KAFKA-8410: Part 1: processor context bounds (#8414)

  Show description for 29e08fd
  vvcephei

  authored
  29e08fd

  Copy full SHA for 29e08fd

• MINOR: Pass one action per unique resource name in KafkaApis.filterAuthorized (#8432)

  Show description for cd1e46c
  dajac

  authored
  cd1e46c

  Copy full SHA for cd1e46c

• KAFKA-9818: improve error message to debug test (#8423)

  Show description for 731630e
  mjsax

  authored
  731630e

  Copy full SHA for 731630e

• MINOR: Should cleanup the tasks after dirty close (#8433)

  Show description for f185016
  

  Boyang Chen

  authored
  f185016

  Copy full SHA for f185016

• MINOR: Fix log cleaner offset range log message (#8435)

  Show description for 9d96523
  hachikuji

  authored
  9d96523

  Copy full SHA for 9d96523

• KAFKA-9815; Ensure consumer always re-joins if JoinGroup fails (#8420)

  Show description for 588e8a5
  rajinisivaram

  authored
  588e8a5

  Copy full SHA for 588e8a5

Commits on Apr 6, 2020

• KAFKA-9753: A few more metrics to add (#8371)

  Show description for 82dff1d
  guozhangwang

  authored
  82dff1d

  Copy full SHA for 82dff1d

• KAFKA-9793: Expand the try-catch for task commit in HandleAssignment (#8402)

  Show description for 712ac52
  

  Boyang Chen

  authored
  712ac52

  Copy full SHA for 712ac52

• KAFKA-9784: Add OffsetFetch to group concurrency test (#8383)

  Show description for 3b8ed0a
  

  Boyang Chen

  authored
  3b8ed0a

  Copy full SHA for 3b8ed0a

Commits on Apr 5, 2020

• MINOR: fix inaccurate RecordBatchIterationBenchmark.measureValidation benchmark (#8428)

  Show description for 37990f9
  lbradstreet

  authored
  37990f9

  Copy full SHA for 37990f9

Commits on Apr 4, 2020

• HOTFIX: fix compilation error (#8424)

  Show description for 0eab920
  

  Boyang Chen

  authored
  0eab920

  Copy full SHA for 0eab920

• MINOR: Remove redundant braces from log message in FetchSessionHandler (#8410)

  Show description for 23b4d87
  kkonstantine

  authored
  23b4d87

  Copy full SHA for 23b4d87

• KAFKA-9820: validateMessagesAndAssignOffsetsCompressed allocates unused iterator (#8422)

  Show description for 46540eb
  lbradstreet

  authored
  46540eb

  Copy full SHA for 46540eb

• MINOR: Refactor StreamsProducer (#8380)

  Show description for ab5e4f5
  mjsax

  authored
  ab5e4f5

  Copy full SHA for ab5e4f5

Commits on Apr 3, 2020

• KAFKA-9807; Protect LSO reads from concurrent high-watermark updates (#8418)

  Show description for d4eb406
  hachikuji

  authored
  d4eb406

  Copy full SHA for d4eb406

• KAFKA-9810: Document Connect Root REST API on / (#8408)

  Show description for 8595267
  kkonstantine

  authored
  8595267

  Copy full SHA for 8595267