Commits

Breadcrumbs

History for

ontrunk

User selector

All users

All time

Commit History

Commits on Feb 5, 2022

• KAFKA-13598: enable idempotence producer by default and validate the configs (#11691)

  Show description for e6db0ca
  showuon

  authored
  e6db0ca

  Copy full SHA for e6db0ca

Commits on Feb 2, 2022

• MINOR: allocate 2MB to offset map in connect EmbeddedKafkaCluster (#11619)

  Show description for 756fa1c
  lbradstreet

  authored
  756fa1c

  Copy full SHA for 756fa1c

Commits on Jan 27, 2022

• KAFKA-13348: Allow Source Tasks to Handle Producer Exceptions (KIP-779) (#11382)

  Show description for 9f2f63e
  TheKnowles

  authored
  9f2f63e

  Copy full SHA for 9f2f63e

Commits on Dec 15, 2021

• MINOR: Timeout waitForBlock in connect BlockingConnectorTest (#11595)

  Show description for b4602e8
  lbradstreet

  authored
  b4602e8

  Copy full SHA for b4602e8

Commits on Dec 9, 2021

• KAFKA-13414: Replace Powermock/EasyMock by Mockito in connect.storage (#11450)

  Show description for f6360d1
  mimaison

  authored
  f6360d1

  Copy full SHA for f6360d1

Commits on Nov 30, 2021

• KAFKA-13469: Block for in-flight record delivery before end-of-life source task offset commit (#11524)

  Show description for f875576
  C0urante

  authored
  f875576

  Copy full SHA for f875576

Commits on Nov 29, 2021

• KAFKA-13472: Correct last-committed offsets tracking for sink tasks after partial revocation (#11526)

  Show description for e8dcbb9
  C0urante

  authored
  e8dcbb9

  Copy full SHA for e8dcbb9

• KAFKA-13200: Fix MirrorMaker2 connector version (#11212)

  Show description for a989149
  mimaison

  authored
  a989149

  Copy full SHA for a989149

Commits on Nov 17, 2021

• KAFKA-13397: MirrorMaker should not mirror topics ending with `.internal` (#11431)

  Show description for ef94af1
  dongjinleekr

  authored
  ef94af1

  Copy full SHA for ef94af1

Commits on Nov 16, 2021

• Revert "MINOR: Remove redundant argument from TaskMetricsGroup#recordCommit (#9642)"

  Show description for 9ea9f0f
  rhauch

  committed
  9ea9f0f

  Copy full SHA for 9ea9f0f

Commits on Nov 15, 2021

• KAFKA-13255: Use config.properties.exclude when mirroring topics (#11401)

  Show description for 8318786
  bdesert

  authored
  8318786

  Copy full SHA for 8318786

Commits on Nov 10, 2021

• KAFKA-13429: ignore bin on new modules (#11415)

  Show description for 214b59b
  jeqo

  authored
  214b59b

  Copy full SHA for 214b59b

• KAFKA-12487: Add support for cooperative consumer protocol with sink connectors (#10563)

  Show description for 39b1bf4
  C0urante

  authored
  39b1bf4

  Copy full SHA for 39b1bf4

Commits on Nov 7, 2021

• KAFKA-12226: Commit source task offsets without blocking on batch delivery (#11323)

  Show description for c1bdfa1
  C0urante

  authored
  c1bdfa1

  Copy full SHA for c1bdfa1

Commits on Oct 11, 2021

• KAFKA-10777: Add additional configuration to control MirrorMaker 2 internal topics naming convention - KIP-690 (#11220)

  Show description for 400d39b
  OmniaGM

  authored
  400d39b

  Copy full SHA for 400d39b

Commits on Oct 8, 2021

• MINOR: Improve decimal scale mismatch error message in Connect (#11384)

  Show description for a9ffabc
  C0urante

  authored
  a9ffabc

  Copy full SHA for a9ffabc

Commits on Sep 30, 2021

• MINOR: Fix the format string supplied to CustomRequestLogger (#11359)

  Show description for db42afd
  kzzhang

  authored
  db42afd

  Copy full SHA for db42afd

Commits on Sep 23, 2021

• MINOR: Replace EasyMock with Mockito in connect:basic-auth-extension (#11321)

  Show description for 509c165
  dengziming

  authored
  509c165

  Copy full SHA for 509c165

Commits on Sep 6, 2021

• KAFKA-13101: Replace EasyMock and PowerMock with Mockito for RestServerTest (#11074)

  Show description for 5193223
  tang7526

  authored
  5193223

  Copy full SHA for 5193223

• KAFKA-13066: Replace EasyMock with Mockito for FileStreamSinkConnectorTest (#11027)

  Show description for 81667e2
  tang7526

  authored
  81667e2

  Copy full SHA for 81667e2

Commits on Sep 2, 2021

• KAFKA-9747: Creating connect reconfiguration URL safely (#11174)

  Show description for 0093b19
  

  akatona84

  and

  Daniel Urban

  authored
  0093b19

  Copy full SHA for 0093b19

Commits on Aug 28, 2021

• KAFKA-10774; Admin API for Describe topic using topic IDs (#9769)

  Show description for 1d22b0d
  dengziming

  authored
  1d22b0d

  Copy full SHA for 1d22b0d

Commits on Aug 3, 2021

• KAFKA-12305: Fix Flatten SMT for array types (#10074)

  Show description for 79788ca
  C0urante

  authored
  79788ca

  Copy full SHA for 79788ca

Commits on Jul 27, 2021

• KAFKA-13139: Empty response after requesting to restart a connector without the tasks results in NPE (#11132)

  Show description for f6f6e52
  kkonstantine

  authored
  f6f6e52

  Copy full SHA for f6f6e52

Commits on Jul 23, 2021

• KAFKA-13126: guard against overflow when computing `joinGroupTimeoutMs` (#11111)

  Show description for 8b1eca1
  ableegoldman

  authored
  8b1eca1

  Copy full SHA for 8b1eca1

Commits on Jul 20, 2021

• KAFKA-9887 fix failed task or connector count on startup failure (#8844)

  Show description for 0314801
  michael-carter-instaclustr

  authored
  0314801

  Copy full SHA for 0314801

Commits on Jul 16, 2021

• KAFKA-13017: Remove excessive logging for sink task deserialization errors (#10945)

  Show description for e01c8a1
  C0urante

  authored
  e01c8a1

  Copy full SHA for e01c8a1

Commits on Jul 14, 2021

• KAFKA-7421: Ensure Connect's PluginClassLoader and DelegatingClassLoader are truly parallel capable and resolve deadlock occurrences (#8259)

  Show description for efd09c2
  gharris1727

  authored
  efd09c2

  Copy full SHA for efd09c2

Commits on Jul 10, 2021

• KAFKA-10675: Add schema name to ConnectSchema.validateValue() error message (#9541)

  Show description for efe6029
  Iskuskov

  authored
  efe6029

  Copy full SHA for efe6029

Commits on Jul 7, 2021

• KAFKA-7613: Enable -Xlint:rawtypes for connect, fixing warnings (#8571)

  Show description for 862f814
  tombentley

  authored
  862f814

  Copy full SHA for 862f814

Commits on Jul 2, 2021

• KAFKA-12717: Remove internal Connect converter properties (KIP-738) (#10854)

  Show description for cad2f5e
  C0urante

  authored
  cad2f5e

  Copy full SHA for cad2f5e

Commits on Jul 1, 2021

• KAFKA-12663: Update FindCoordinator to support batch lookups (KIP-699) (#10743)

  Show description for f5d5f65
  mimaison

  authored
  f5d5f65

  Copy full SHA for f5d5f65

• KAFKA-9726: Add IdentityReplicationPolicy to MirrorMaker2 (#10652)

  Show description for 93f5737
  

  4 peopleauthored
  93f5737

  Copy full SHA for 93f5737

• KAFKA-4793: Connect API to restart connector and tasks (KIP-745) (#10822)

  Show description for 527ba11
  kpatelatwork

  authored
  527ba11

  Copy full SHA for 527ba11

Commits on Jun 29, 2021

• KAFKA-12379: Allow configuring the location of the offset-syncs topic with MirrorMaker2 (#10221)

  Show description for 3c4be0b
  mimaison

  authored
  3c4be0b

  Copy full SHA for 3c4be0b