Commits

Branch selector

 trunk

User selector

vamossagar12

All time

Commit History

Commits on Dec 15, 2022

• Removing Multicasting partitioner for IQ (#12977)

  Show description for a46d16e
  vamossagar12

  authored
  a46d16e

  Copy full SHA for a46d16e

Commits on Dec 13, 2022

• KAFKA-13602: Remove unwanted logging in RecordCollectorImpl.java (#12985)

  Show description for 73ea698
  vamossagar12

  authored
  73ea698

  Copy full SHA for 73ea698

Commits on Dec 10, 2022

• KAFKA-14454: Making unique StreamsConfig for tests (#12971)

  Show description for 2fa1879
  vamossagar12

  authored
  2fa1879

  Copy full SHA for 2fa1879

Commits on Dec 6, 2022

• KAFKA-13602: Adding ability to multicast records (#12803)

  Show description for 77e294e
  vamossagar12

  authored
  77e294e

  Copy full SHA for 77e294e

Commits on Dec 1, 2022

• KAFKA-13152: Add cache size metrics (#12778)

  Show description for 6663acf
  vamossagar12

  authored
  6663acf

  Copy full SHA for 6663acf

Commits on Nov 15, 2022

• KAFKA-12495: Exponential backoff retry to prevent rebalance storms when worker joins after revoking rebalance (#12561)

  Show description for 09da44e
  vamossagar12

  authored
  09da44e

  Copy full SHA for 09da44e

Commits on Nov 7, 2022

• Kafka 12960: Follow up Commit to filter expired records from Windowed/Session Stores (#12756)

  Show description for 7fd6a9b
  vamossagar12

  authored
  7fd6a9b

  Copy full SHA for 7fd6a9b

Commits on Oct 21, 2022

• KAFKA-13152: KIP-770, cache size config deprecation (#12758)

  Show description for 9a79389
  vamossagar12

  authored
  9a79389

  Copy full SHA for 9a79389

Commits on Oct 13, 2022

• KAFKA-12960: Enforcing strict retention time for WindowStore and Sess… (#11211)

  Show description for 07c1002
  vamossagar12

  authored
  07c1002

  Copy full SHA for 07c1002

Commits on Jul 28, 2022

• KAFKA-14012: Add warning to closeQuietly documentation about method references of null objects (#12321)

  Show description for 3ddb623
  vamossagar12

  authored
  3ddb623

  Copy full SHA for 3ddb623

• KAFKA-14007: Close header converters during Connect task shutdown (#12309)

  Show description for 0c5f5a7
  vamossagar12

  authored
  0c5f5a7

  Copy full SHA for 0c5f5a7

Commits on Jul 7, 2022

• KAFKA-13846: Follow up PR to address review comments (#12297)

  Show description for 5a1bac2
  vamossagar12

  authored
  5a1bac2

  Copy full SHA for 5a1bac2

Commits on Jun 13, 2022

• KAFKA-13846: Adding overloaded metricOrElseCreate method (#12121)

  Show description for 5cab11c
  vamossagar12

  authored
  5cab11c

  Copy full SHA for 5cab11c

Commits on May 14, 2022

• KAFKA-13746: Attempt to fix flaky test by waiting on metadata update (#12104)

  Show description for f96e381
  vamossagar12

  authored
  f96e381

  Copy full SHA for f96e381

Commits on Mar 22, 2022

• KAFKA-13152: Replace "buffered.records.per.partition" with "input.buffer.max.bytes" (#11796)

  Show description for 0924fd3
  vamossagar12

  authored
  0924fd3

  Copy full SHA for 0924fd3

Commits on Jan 28, 2022

• KAFKA-13152: Replace "buffered.records.per.partition" with "input.buffer.max.bytes" (#11424)

  Show description for 14c6030
  vamossagar12

  authored
  14c6030

  Copy full SHA for 14c6030

Commits on Sep 28, 2021

• KAFKA-12486: Enforce Rebalance when a TaskCorruptedException is throw… (#11076)

  Show description for 7e57300
  vamossagar12

  authored
  7e57300

  Copy full SHA for 7e57300

Commits on Jul 14, 2021

• KAFKA-12925: adding presfixScan operation for missed implementations (#10877)

  Show description for f413435
  vamossagar12

  authored
  f413435

  Copy full SHA for f413435

Commits on May 17, 2021

• KAFKA-12313: KIP-725: Streamlining configs for Windowed Deserialisers (#10542)

  Show description for b9acc49
  vamossagar12

  authored
  b9acc49

  Copy full SHA for b9acc49

Commits on May 5, 2021

• KAFKA-10767: Adding test cases for all, reverseAll and reverseRange for ThreadCache (#9779)

  Show description for 9a71468
  vamossagar12

  authored
  9a71468

  Copy full SHA for 9a71468

Commits on Mar 2, 2021

• KAFKA-10766: Unit test cases for RocksDBRangeIterator (#9717)

  Show description for 4c5867a
  vamossagar12

  authored
  4c5867a

  Copy full SHA for 4c5867a

• KAFKA-12289: Adding test cases for prefix scan in InMemoryKeyValueStore (#10052)

  Show description for b2075a0
  vamossagar12

  authored
  b2075a0

  Copy full SHA for b2075a0

Commits on Feb 24, 2021

• MINOR: Add release documentation for KIP-614 (#10051)

  Show description for 8bd0e21
  vamossagar12

  authored
  8bd0e21

  Copy full SHA for 8bd0e21

Commits on Feb 3, 2021

• KAFKA-10648: Add Prefix Scan support to State Stores (#9508)

  Show description for 51833bf
  vamossagar12

  authored
  51833bf

  Copy full SHA for 51833bf

Commits on Dec 22, 2020

• KAFKA-10828; Replacing endorsing with acknowledging for voters (#9737)

  Show description for d5151f6
  vamossagar12

  authored
  d5151f6

  Copy full SHA for d5151f6

Commits on Dec 9, 2020

• KAFKA-10634; Adding LeaderId to voters list in LeaderChangeMessage along with granting voters (#9539)

  Show description for 99b5e4f
  vamossagar12

  authored
  99b5e4f

  Copy full SHA for 99b5e4f

Commits on Oct 15, 2020

• KAFKA-10559: Not letting TimeoutException shutdown the app during internal topic validation (#9432)

  Show description for a85802f
  vamossagar12

  authored
  a85802f

  Copy full SHA for a85802f