Commits

Branch selector

 trunk

User selector

All users

Datepicker

All time

Commit History

Commits on May 8, 2024

• KAFKA-16640 Replace TestUtils#resource by scala.util.Using (#15881)

  Show description for f74f596
  frankvicky

  authored
  f74f596

  Copy full SHA for f74f596

• KAFKA-10199: Revoke tasks from state updater with new remove (#15871)

  Show description for f7b242f
  cadonna

  authored
  f7b242f

  Copy full SHA for f7b242f

• MINOR: Remove dev_version parameter from streams tests (#15874)

  Show description for 3b43edd
  lucasbru

  authored
  3b43edd

  Copy full SHA for 3b43edd

• KAFKA-16511: Fix the leaking tiered segments during segment deletion (#15817)

  Show description for 8655094
  kamalcph

  authored
  8655094

  Copy full SHA for 8655094

• MINOR: Correct connector scheduled rebalance logs (#15875)

  Show description for 5f933ac
  yuz10

  authored
  5f933ac

  Copy full SHA for 5f933ac

• KAFKA-16678 Remove variable "unimplementedquorum" (#15879)

  Show description for a0f1658
  frankvicky

  authored
  a0f1658

  Copy full SHA for a0f1658

Commits on May 7, 2024

• KAFKA-15018: Write connector tombstone offsets to secondary store before primary store (#13801)

  Show description for 525b9b1
  vamossagar12

  authored
  525b9b1

  Copy full SHA for 525b9b1

• KAFKA-14226: Introduce FieldPath abstraction and nested path support for ExtractField SMT (#15379)

  Show description for a4c6cef
  jeqo

  authored
  a4c6cef

  Copy full SHA for a4c6cef

• KAFKA-13328, KAFKA-13329 (2): Add custom preflight validation support for connector header, key, and value converters (#14309)

  Show description for 05df104
  C0urante

  authored
  05df104

  Copy full SHA for 05df104

• KAFKA-16307; Fix coordinator thread idle ratio (#15835)

  Show description for 21bf715
  jeffkbkim

  authored
  21bf715

  Copy full SHA for 21bf715

• KAFKA-10199: Remove lost tasks in state updater with new remove (#15870)

  Show description for cb35ddc
  cadonna

  authored
  cb35ddc

  Copy full SHA for cb35ddc

• KAFKA-16665: Allow to initialize newly assigned partition's positions without allowing fetching while callback runs (#15856)

  Show description for ea485a7
  lianetm

  authored
  ea485a7

  Copy full SHA for ea485a7

• KAFKA-16615; JoinGroup API for upgrading ConsumerGroup (#15798)

  Show description for 459eaec
  dongnuo123

  authored
  459eaec

  Copy full SHA for 459eaec

• MINOR: log newly created processId (#15851)

  Show description for d76352e
  mjsax

  authored
  d76352e

  Copy full SHA for d76352e

• KAFKA-16593 Rewrite DeleteConsumerGroupsTest by ClusterTestExtensions (#15766)

  Show description for 0de3b7c
  frankvicky

  authored
  0de3b7c

  Copy full SHA for 0de3b7c

• KAFKA-16470 kafka-dump-log --offsets-decoder should support new records (#15652)

  Show description for 0df340d
  dajac

  authored
  0df340d

  Copy full SHA for 0df340d

• KAFKA-16539 Fix IncrementalAlterConfigs during ZK migration (#15744)

  Show description for fe8ccbc
  mumrah

  authored
  fe8ccbc

  Copy full SHA for fe8ccbc

• KAFKA-16608 Honour interrupted thread state on KafkaConsumer.poll (#15803)

  Show description for 4c4ae6e
  AndrewJSchofield

  authored
  4c4ae6e

  Copy full SHA for 4c4ae6e

Commits on May 6, 2024

• KAFKA-16356: Remove class-name dispatch in RemoteLogMetadataSerde (#15620)

  Show description for aeca384
  linu-shibu

  authored
  aeca384

  Copy full SHA for aeca384

• KAFKA-16646: KAFKA-16646Don't run cve scan job on forks (#15831)

  Show description for 0b4eaef
  VedarthConfluent

  authored
  0b4eaef

  Copy full SHA for 0b4eaef

• MINOR: Remove `ConsumerGroupPartitionMetadataValue.Epoch` field (#15854)

  Show description for 4275433
  dajac

  authored
  4275433

  Copy full SHA for 4275433

• KAFKA-16393 read/write sequence of buffers correctly (#15571)

  Show description for 5c96ad6
  ocadaruma

  authored
  5c96ad6

  Copy full SHA for 5c96ad6

• KAFKA-14588 [3/N] ConfigCommandTest rewritten in java (#15850)

  Show description for 6a8977e
  nizhikov

  authored
  6a8977e

  Copy full SHA for 6a8977e

• KAFKA-10199: Add remove operation with future to state updater (#15852)

  Show description for 366aeab
  cadonna

  authored
  366aeab

  Copy full SHA for 366aeab

• MINOR: Replaced Utils.join() with JDK API. (#15823)

  Show description for 55a00be
  chiacyu

  authored
  55a00be

  Copy full SHA for 55a00be

• KAFKA-16223 Replace EasyMock/PowerMock with Mockito for KafkaConfigBackingStoreTest (2/3) (#15841)

  Show description for 41f5bf8
  hgeraldino

  authored
  41f5bf8

  Copy full SHA for 41f5bf8

• KAFKA-16659 KafkaConsumer#position() does not respect wakup when group protocol is CONSUMER (#15853)

  Show description for 970ac07
  FrankYang0529

  authored
  970ac07

  Copy full SHA for 970ac07

Commits on May 5, 2024

• MINOR: remove redundant check in KafkaClusterTestKit (#15858)

  Show description for 25118ce
  johnnychhsu

  authored
  25118ce

  Copy full SHA for 25118ce

Commits on May 4, 2024

• KAFKA-16207; KRaft's internal log listener to update voter set (#15671)

  Show description for bfe81d6
  jsancio

  authored
  bfe81d6

  Copy full SHA for bfe81d6

• KAFKA-16427 KafkaConsumer#position() does not respect timeout when group protocol is CONSUMER (#15843)

  Show description for 9b8aac2
  kirktrue

  authored
  9b8aac2

  Copy full SHA for 9b8aac2

Commits on May 3, 2024

• KAFKA-16655: Deflake ZKMigrationIntegrationTest.testDualWrite #15845

  Show description for 1fd3915
  ahuang98

  authored
  1fd3915

  Copy full SHA for 1fd3915

• MINOR: ConsumerGroup#getOrMaybeCreateMember should not add the member to the group (#15847)

  Show description for 2c0b8b6
  dajac

  authored
  2c0b8b6

  Copy full SHA for 2c0b8b6

• KAFKA-10199: Accept only one task per element in output queue for failed tasks (#15849)

  Show description for 240243b
  cadonna

  authored
  240243b

  Copy full SHA for 240243b

• KAFKA-16572 allow defining number of disks per broker in ClusterTest (#15745)

  Show description for 87390f9
  FrankYang0529

  authored
  87390f9

  Copy full SHA for 87390f9

Commits on May 2, 2024

• KAFKA-16624: Don't generate useless PartitionChangeRecord on older MV (#15810)

  Show description for a3f2414
  cmccabe

  authored
  a3f2414

  Copy full SHA for a3f2414

Pagination

Previous

Next