| /dports/net/elixir-kafka_ex/kafka_ex-0.10.0/lib/kafka_ex/protocol/ |
| H A D | api_versions.ex | 22 defstruct error_code: nil, api_versions: nil, throttle_time_ms: nil
27 throttle_time_ms: integer
85 throttle_time_ms: @default_throttle_time
88 {v, <<throttle_time_ms::32-signed>>} when v in [1, 2] ->
91 throttle_time_ms: throttle_time_ms
|
| /dports/net/elixir-kafka_ex/kafka_ex-0.10.0/test/integration/ |
| H A D | server0_p_10_p_1_test.exs | 41 throttle_time_ms: _
|
| /dports/net/py-kafka-python/kafka-python-1.4.5/kafka/producer/ |
| H A D | sender.py | 208 self._sensors.record_throttle_time(response.throttle_time_ms, node=node_id)
495 def record_throttle_time(self, throttle_time_ms, node=None): argument
496 self.produce_throttle_time_sensor.record(throttle_time_ms)
|
| /dports/net/librdkafka/librdkafka-1.8.2/src-cpp/ |
| H A D | HandleImpl.cpp | 94 int throttle_time_ms, in throttle_cb_trampoline() argument
101 event.throttle_time_ = throttle_time_ms; in throttle_cb_trampoline()
|
| H A D | rdkafkacpp_int.h | 65 int32_t broker_id, int throttle_time_ms,
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src-cpp/ |
| H A D | HandleImpl.cpp | 93 int throttle_time_ms, in throttle_cb_trampoline() argument
100 event.throttle_time_ = throttle_time_ms; in throttle_cb_trampoline()
|
| H A D | rdkafkacpp_int.h | 65 int32_t broker_id, int throttle_time_ms,
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src-cpp/ |
| H A D | HandleImpl.cpp | 94 int throttle_time_ms, in throttle_cb_trampoline() argument
101 event.throttle_time_ = throttle_time_ms; in throttle_cb_trampoline()
|
| H A D | rdkafkacpp_int.h | 65 int32_t broker_id, int throttle_time_ms,
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/ |
| H A D | rdkafka_conf.h | 439 int32_t broker_id, int throttle_time_ms,
|
| H A D | rdkafka.h | 1863 int throttle_time_ms,
|
| H A D | rdkafka_conf.c | 2534 int throttle_time_ms, in rd_kafka_conf_set_throttle_cb() argument
|
| /dports/net/librdkafka/librdkafka-1.8.2/src/ |
| H A D | rdkafka_conf.h | 451 int32_t broker_id, int throttle_time_ms,
|
| H A D | rdkafka.h | 2004 int throttle_time_ms,
|
| H A D | rdkafka_conf.c | 2771 int throttle_time_ms, in rd_kafka_conf_set_throttle_cb() argument
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/ |
| H A D | rdkafka_conf.h | 450 int32_t broker_id, int throttle_time_ms,
|
| H A D | rdkafka.h | 2004 int throttle_time_ms,
|
| /dports/net/librdkafka/librdkafka-1.8.2/examples/ |
| H A D | rdkafka_performance.c | 145 int32_t broker_id, int throttle_time_ms, in throttle_cb() argument
147 printf("%% THROTTLED %dms by %s (%"PRId32")\n", throttle_time_ms, in throttle_cb()
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/examples/ |
| H A D | rdkafka_performance.c | 145 int32_t broker_id, int throttle_time_ms, in throttle_cb() argument
147 printf("%% THROTTLED %dms by %s (%"PRId32")\n", throttle_time_ms, in throttle_cb()
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/examples/ |
| H A D | rdkafka_performance.c | 145 int32_t broker_id, int throttle_time_ms, in throttle_cb() argument
147 printf("%% THROTTLED %dms by %s (%"PRId32")\n", throttle_time_ms, in throttle_cb()
|
| /dports/net/py-confluent-kafka/confluent-kafka-1.2.0/confluent_kafka/src/ |
| H A D | confluent_kafka.c | 1259 int throttle_time_ms, void *opaque) { in throttle_cb() argument
1279 args = Py_BuildValue("(sid)", broker_name, broker_id, (double)throttle_time_ms/1000); in throttle_cb()
|
| /dports/net/kcat/kcat-1.7.0/ |
| H A D | kcat.c | 669 int32_t broker_id, int throttle_time_ms, void *opaque){ in throttle_cb() argument
671 broker_name, broker_id, throttle_time_ms); in throttle_cb()
|
| /dports/net/py-kafka-python/kafka-python-1.4.5/ |
| H A D | CHANGES.md | 552 * Fix ProduceResponse v2 throttle_time_ms
663 * fix throttle_time_ms sensor handling (zackdever pr 667)
700 * KAFKA-2136: support Fetch and Produce v1 (throttle_time_ms)
|
| /dports/net/py-kafka-python/kafka-python-1.4.5/kafka/consumer/ |
| H A D | fetcher.py | 759 self._sensors.fetch_throttle_time_sensor.record(response.throttle_time_ms)
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/src/ |
| H A D | bindings.rs | 675 throttle_time_ms: c_int, in rd_kafka_conf_set_throttle_cb()
|