Code

KIP 714 with compression support#4721

Code

Merged

anchitj merged 99 commits intomasterconfluentinc/librdkafka:masterfrom dev_kip_714_mock_broker_integration_tests_master_merge_with_compressionconfluentinc/librdkafka:dev_kip_714_mock_broker_integration_tests_master_merge_with_compressionCopy head branch name to clipboardJul 8, 2024

+10,282-122

Commits

Commits on Jul 25, 2023

• Add boilerplate for the entire flow (#4365)

  milindl

  authored
  3f0eed3

Commits on Jul 27, 2023

• Added new data type UUID for topic id. Added topic id support in Metadata Response.

  

  pranavrth

  authored and

  milindl

  committed
  56fa55a

Commits on Aug 1, 2023

• Merge Get and Push Protocol (#4377)

  Show description for 9546d71
  

  anchitj

  and

  milindl

  authored
  9546d71

• Clang format fixes

  anchitj

  committed
  e11aa51

Commits on Aug 2, 2023

• Fix memory leaks (#4378)

  milindl

  authored
  ca6a8e5

Commits on Aug 7, 2023

• Add broker selection and client termination [KIP-714] (#4382)

  Show description for ef07a95
  milindl

  authored
  ef07a95

Commits on Aug 21, 2023

• Integrate nanopb to encode and decode metrics (#4388)

  Show description for 530eb0b
  anchitj

  authored
  530eb0b

Commits on Aug 29, 2023

• Handle delta temporality and some code refactoring (#4410)

  Show description for 5c943ba
  anchitj

  authored
  5c943ba

Commits on Aug 31, 2023

• Use rd_kafka_compression_t (#4419)

  anchitj

  authored
  9e3cf26

Commits on Sep 7, 2023

• Add method to get requests from mock cluster

  milindl

  committed
  21f7072

Commits on Sep 14, 2023

• Fix to ns

  anchitj

  committed
  f1c4fc4

Commits on Sep 20, 2023

• Add capacity in mock broker to change PushIntervalMs

  milindl

  committed
  7fdbfbe

• Fix memory leak

  milindl

  committed
  e6a9d66

• Fix jitter: should not be decimal

  milindl

  committed
  e0b4f3e

• Add test for telemetry using mock broker

  milindl

  committed
  d7e4b47

Commits on Sep 28, 2023

• Address comments

  milindl

  committed
  a614d2c

Commits on Sep 29, 2023

• Unit tests push telemetry encode decode (#4440)

  Show description for 1216b39
  anchitj

  authored
  1216b39

Commits on Nov 7, 2023

• Initial code for metrics compression

  anchitj

  committed
  4ed6abd

• Style and some bug fixes

  anchitj

  committed
  3d66f64

Commits on Nov 8, 2023

• Little refactoring

  anchitj

  committed
  88dcfc1

Commits on Dec 6, 2023

• Add max telemetry bytes (#4507)

  Show description for 81913fe
  anchitj

  authored
  81913fe

Commits on Dec 7, 2023

• Add other producer metrics

  anchitj

  committed
  ccc1a26

• More changes

  anchitj

  committed
  b6c04ac

• Add enable.metrics.push config

  anchitj

  committed
  94545fe

• Fix bugs

  anchitj

  committed
  aa8a668

• Refactor

  anchitj

  committed
  8c38f8e

• Fix warnings

  anchitj

  committed
  3987849

• Fix UT

  anchitj

  committed
  4d1d192

• Nullify after free

  anchitj

  committed
  2f6afa2

• Fix bugs

  anchitj

  committed
  eff9351

• Refactor

  anchitj

  committed
  15fd89c

• PR Feedback

  anchitj

  committed
  d534720

Commits on Dec 11, 2023

• Upgrade vcpkg (#4531)

  

  emasab

  authored and

  anchitj

  committed
  7a911d9

• Add available consumer metrics

  anchitj

  committed
  40489d4

• Style fix

  anchitj

  committed
  4bc1c48

• PR Feedback

  anchitj

  committed
  430745b

• labels

  anchitj

  committed
  e9b2bba

• Add per broker labels

  anchitj

  committed
  73d14ee

• Style fix

  anchitj

  committed
  4bd7946

• Update all metrics subscribed string

  anchitj

  committed
  34fca5f

• Style fix

  anchitj

  committed
  ebd36c8

• PR Feedback

  anchitj

  committed
  a5988d6

• Update matching logic

  anchitj

  committed
  52a6150

• Style fix

  anchitj

  committed
  5a4b645

• Add per broker labels

  anchitj

  committed
  36c4f83

• Style fix

  anchitj

  committed
  217ceca

• Bug fixes

  anchitj

  committed
  ce9f6a1

• Don't push terminating telemetry if metrics aren't enabled

  anchitj

  committed
  5806b0f

• Match with temporality

  anchitj

  committed
  7525eb4

• Style fix

  anchitj

  committed
  d6cdce5

• Add new broker errors

  anchitj

  committed
  89cfa2a

• Memory leak fixes

  anchitj

  committed
  8ca308b

• PR feedback

  anchitj

  committed
  40edc31

• Style fix

  anchitj

  committed
  e6a88cb

• Immediate schedule getTelemetry for unknown subscription id

  anchitj

  committed
  d541a2b

Commits on Dec 12, 2023

• Rebase fix

  anchitj

  committed
  6abdf47

• Use rd_uclock

  anchitj

  committed
  b92899b

Commits on Dec 15, 2023

• Master merge

  anchitj

  committed
  ccf2ba9

• Master merge

  anchitj

  committed
  c30a432

Commits on Feb 1, 2024

• Add more mock test

  anchitj

  committed
  8d7e70b

• Master merge

  anchitj

  committed
  c815cb5

• Style fix

  anchitj

  committed
  e516730

Commits on Apr 3, 2024

• Merge branch 'master' into dev_kip_714_mock_broker_integration_tests_master_merge

  anchitj

  committed
  3cb7286

Commits on May 10, 2024

• Merge master

  anchitj

  committed
  d15171b

• Merge compression

  anchitj

  committed
  9bf7966

Commits on Jun 21, 2024

• Merge branch 'master' into dev_kip_714_mock_broker_integration_tests_master_merge_with_compression

  anchitj

  committed
  5c17295

Commits on Jun 25, 2024

• PR feedback first phase

  anchitj

  committed
  9a0c0c2

• Merge branch 'master' into dev_kip_714_mock_broker_integration_tests_master_merge_with_compression

  anchitj

  committed
  604d18f

• Minor fixes

  anchitj

  committed
  ae64b34

Commits on Jun 28, 2024

• Segfault fixes

  anchitj

  committed
  4f2d428

Commits on Jul 1, 2024

• PR Feedback 3rd round

  anchitj

  committed
  2772552

• Use rkb instead of rkb_selected

  anchitj

  committed
  b537675

• Write to rbuf before returning

  anchitj

  committed
  5192995

• Use rd_avg_rollover instead of rd_avg_current

  Show description for 77fc568
  anchitj

  committed
  77fc568

• Fix exp_max for avg counters

  anchitj

  committed
  1a04f33

• Fix unit test

  anchitj

  committed
  4ac880c

Commits on Jul 2, 2024

• Reset current avg's max

  anchitj

  committed
  4566133

• Don't use histogram in telemetry avgs

  anchitj

  committed
  e19102f

• Remove compress direct methods

  anchitj

  committed
  97589f3

Commits on Jul 3, 2024

• Revert "Don't use histogram in telemetry avgs"

  Show description for 97b48fa
  anchitj

  committed
  97b48fa

• PR Feedback 4th round

  anchitj

  committed
  a5b398d

• Replace TELTERM by TERM

  anchitj

  committed
  9ae5c1c

• Move first_push to telemetry.c

  anchitj

  committed
  387ae01

• Merge branch 'master' into dev_kip_714_mock_broker_integration_tests_master_merge_with_compression

  anchitj

  committed
  7a36b53

• Fix unit test

  anchitj

  committed
  77a75b4

• PR feedback 5th round

  anchitj

  committed
  23c3b8f

• Rename interface to decode_interface

  anchitj

  committed
  69f9dcf

• PR feedback 6th round

  anchitj

  committed
  77ce834

Commits on Jul 4, 2024

• PR feedback

  anchitj

  committed
  1924e3f

• PR feedback 7th round

  anchitj

  committed
  476038a

Commits on Jul 5, 2024

• PR feedback 8th round

  anchitj

  committed
  dd7d1fc

• Merge branch 'master' into dev_kip_714_mock_broker_integration_tests_master_merge_with_compression

  anchitj

  committed
  bb53d5e

• Change failure message in rd_assert

  anchitj

  committed
  b78751c

• PR feedback 9th round

  anchitj

  committed
  652b0ea

• Update copyright year rdkafka_conf.h

  anchitj

  committed
  40b0ad8

• Remove arg being cast as test_data

  anchitj

  committed
  46e4579

• Add changelog entry

  anchitj

  committed
  0fbc703

• Remove changes to 0009-mock_cluster.c

  anchitj

  committed
  bbd316b

Commits on Jul 8, 2024

• PR feedback 10th round

  anchitj

  committed
  4732ff6