/dports/net/librdkafka/librdkafka-1.8.2/packaging/cmake/ |
H A D | parseversion.cmake | 38 # Parse the file given by <filepath> for the RD_KAFKA_VERSION constant 47 … file(STRINGS ${path} rdkafka_version_def REGEX "#define *RD_KAFKA_VERSION *\(0x[a-f0-9]*\)\.*") 48 …string(REGEX REPLACE "#define *RD_KAFKA_VERSION *0x" "" rdkafka_version_hex ${rdkafka_version_de…
|
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/packaging/cmake/ |
H A D | parseversion.cmake | 38 # Parse the file given by <filepath> for the RD_KAFKA_VERSION constant 47 … file(STRINGS ${path} rdkafka_version_def REGEX "#define *RD_KAFKA_VERSION *\(0x[a-f0-9]*\)\.*") 48 …string(REGEX REPLACE "#define *RD_KAFKA_VERSION *0x" "" rdkafka_version_hex ${rdkafka_version_de…
|
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/packaging/cmake/ |
H A D | parseversion.cmake | 38 # Parse the file given by <filepath> for the RD_KAFKA_VERSION constant 47 … file(STRINGS ${path} rdkafka_version_def REGEX "#define *RD_KAFKA_VERSION *\(0x[a-f0-9]*\)\.*") 48 …string(REGEX REPLACE "#define *RD_KAFKA_VERSION *0x" "" rdkafka_version_hex ${rdkafka_version_de…
|
/dports/net/py-confluent-kafka/confluent-kafka-1.2.0/confluent_kafka/src/ |
H A D | Producer.c | 267 rd_kafka_version(), RD_KAFKA_VERSION); in Producer_produce() 279 rd_kafka_version(), RD_KAFKA_VERSION); in Producer_produce() 379 #if RD_KAFKA_VERSION >= 0x00090300 in Producer_flush() 386 #if RD_KAFKA_VERSION >= 0x00090300 in Producer_flush()
|
H A D | Metadata.c | 263 #if RD_KAFKA_VERSION >= 0x000b0500 in c_metadata_to_py() 278 #if RD_KAFKA_VERSION >= 0x000b0500 in c_metadata_to_py()
|
H A D | Consumer.c | 497 #if RD_KAFKA_VERSION < 0x000b0000 in Consumer_store_offsets() 503 rd_kafka_version(), RD_KAFKA_VERSION); in Consumer_store_offsets() 817 #if RD_KAFKA_VERSION < 0x000b0000 in Consumer_offsets_for_times() 823 rd_kafka_version(), RD_KAFKA_VERSION); in Consumer_offsets_for_times()
|
H A D | confluent_kafka.h | 51 #if RD_KAFKA_VERSION < MIN_RD_KAFKA_VERSION
|
/dports/net/kcat/kcat-1.7.0/ |
H A D | kcat.h | 56 #if RD_KAFKA_VERSION >= 0x000b0500 130 #if RD_KAFKA_VERSION >= 0x00090300
|
H A D | kcat.c | 54 #if RD_KAFKA_VERSION >= 0x01040000 58 #if RD_KAFKA_VERSION >= 0x01060000 155 #if RD_KAFKA_VERSION >= 0x010500ff in dr_msg_cb() 667 #if RD_KAFKA_VERSION >= 0x00090000 1014 #if RD_KAFKA_VERSION >= 0x00090300 in consumer_run() 1364 #if RD_KAFKA_VERSION >= 0x00090300 in usage() 1435 #if RD_KAFKA_VERSION >= 0x000902ff in usage() 1509 #if RD_KAFKA_VERSION >= 0x01000000 in error_cb() 1716 #if RD_KAFKA_VERSION >= 0x00090000 in try_conf_set() 2070 #if RD_KAFKA_VERSION >= 0x00090300 in argparse()
|
H A D | tools.c | 57 #if RD_KAFKA_VERSION >= 0x00090300 in query_offsets_by_time()
|
H A D | json.c | 57 #if RD_KAFKA_VERSION >= 0x000902ff in fmt_msg_output_json() 81 #if RD_KAFKA_VERSION >= 0x010500ff in fmt_msg_output_json()
|
H A D | format.c | 513 #if RD_KAFKA_VERSION >= 0x000902ff in fmt_msg_output_str()
|
/dports/net/pecl-rdkafka/rdkafka-4.0.4/ |
H A D | rdkafka.c | 42 #if RD_KAFKA_VERSION < 0x000b0000 824 REGISTER_LONG_CONSTANT("RD_KAFKA_BUILD_VERSION", RD_KAFKA_VERSION, CONST_CS | CONST_PERSISTENT); in PHP_MINIT_FUNCTION() 897 (RD_KAFKA_VERSION & 0xFF000000) >> 24, in PHP_MINFO_FUNCTION() 898 (RD_KAFKA_VERSION & 0x00FF0000) >> 16, in PHP_MINFO_FUNCTION() 899 (RD_KAFKA_VERSION & 0x0000FF00) >> 8, in PHP_MINFO_FUNCTION() 900 (RD_KAFKA_VERSION & 0x000000FF) in PHP_MINFO_FUNCTION()
|
H A D | config.m4 | 53 #if RD_KAFKA_VERSION >= 0x000b0000
|
/dports/net/librdkafka/librdkafka-1.8.2/packaging/cp/ |
H A D | check_features.c | 16 rd_kafka_version_str(), rd_kafka_version(), RD_KAFKA_VERSION); in main()
|
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/packaging/cp/ |
H A D | check_features.c | 16 rd_kafka_version_str(), rd_kafka_version(), RD_KAFKA_VERSION); in main()
|
/dports/net/pecl-rdkafka/rdkafka-4.0.4/tests/ |
H A D | conf_callbacks.phpt | 5 RD_KAFKA_VERSION >= 0x090000 || die("skip librdkafka too old");
|
H A D | bug115.phpt | 13 if (RD_KAFKA_VERSION >= 0x090000 && false !== getenv('TEST_KAFKA_BROKER_VERSION')) {
|
H A D | produce_consume.phpt | 13 if (RD_KAFKA_VERSION >= 0x090000 && false !== getenv('TEST_KAFKA_BROKER_VERSION')) {
|
H A D | conf_callbacks_integration.phpt | 5 RD_KAFKA_VERSION >= 0x090000 || die("skip librdkafka too old");
|
H A D | message_headers.phpt | 5 RD_KAFKA_VERSION >= 0x000b04ff || die("skip librdkafka too old");
|
H A D | produce_consume_queue.phpt | 15 if (RD_KAFKA_VERSION >= 0x090000 && false !== getenv('TEST_KAFKA_BROKER_VERSION')) {
|
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/packaging/cp/ |
H A D | check_features.c | 16 rd_kafka_version_str(), rd_kafka_version(), RD_KAFKA_VERSION); in main()
|
/dports/sysutils/rsyslog8/rsyslog-8.2112.0/plugins/imkafka/ |
H A D | imkafka.c | 414 #if RD_KAFKA_VERSION >= 0x00090001 in ATTR_NONNULL() 428 #if RD_KAFKA_VERSION < 0x00090001 in ATTR_NONNULL() 729 #if RD_KAFKA_VERSION < 0x00090001 in shutdownKafkaWorkers()
|
/dports/sysutils/rsyslog8/rsyslog-8.2112.0/plugins/omkafka/ |
H A D | omkafka.c | 760 #if RD_KAFKA_VERSION >= 0x00090400 784 #if RD_KAFKA_VERSION >= 0x00090400 875 #if RD_KAFKA_VERSION >= 0x00090400 1138 #if RD_KAFKA_VERSION >= 0x010001ff 1166 # if RD_KAFKA_VERSION < 0x00090001 1304 # if RD_KAFKA_VERSION >= 0x00090001 1316 # if RD_KAFKA_VERSION < 0x00090001
|