Home
last modified time | relevance | path

Searched refs:RD_KAFKA_VERSION (Results 1 – 25 of 39) sorted by relevance

12

/dports/net/librdkafka/librdkafka-1.8.2/packaging/cmake/
H A Dparseversion.cmake38 # 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 Dparseversion.cmake38 # 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 Dparseversion.cmake38 # 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 DProducer.c267 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 DMetadata.c263 #if RD_KAFKA_VERSION >= 0x000b0500 in c_metadata_to_py()
278 #if RD_KAFKA_VERSION >= 0x000b0500 in c_metadata_to_py()
H A DConsumer.c497 #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 Dconfluent_kafka.h51 #if RD_KAFKA_VERSION < MIN_RD_KAFKA_VERSION
/dports/net/kcat/kcat-1.7.0/
H A Dkcat.h56 #if RD_KAFKA_VERSION >= 0x000b0500
130 #if RD_KAFKA_VERSION >= 0x00090300
H A Dkcat.c54 #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 Dtools.c57 #if RD_KAFKA_VERSION >= 0x00090300 in query_offsets_by_time()
H A Djson.c57 #if RD_KAFKA_VERSION >= 0x000902ff in fmt_msg_output_json()
81 #if RD_KAFKA_VERSION >= 0x010500ff in fmt_msg_output_json()
H A Dformat.c513 #if RD_KAFKA_VERSION >= 0x000902ff in fmt_msg_output_str()
/dports/net/pecl-rdkafka/rdkafka-4.0.4/
H A Drdkafka.c42 #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 Dconfig.m453 #if RD_KAFKA_VERSION >= 0x000b0000
/dports/net/librdkafka/librdkafka-1.8.2/packaging/cp/
H A Dcheck_features.c16 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 Dcheck_features.c16 rd_kafka_version_str(), rd_kafka_version(), RD_KAFKA_VERSION); in main()
/dports/net/pecl-rdkafka/rdkafka-4.0.4/tests/
H A Dconf_callbacks.phpt5 RD_KAFKA_VERSION >= 0x090000 || die("skip librdkafka too old");
H A Dbug115.phpt13 if (RD_KAFKA_VERSION >= 0x090000 && false !== getenv('TEST_KAFKA_BROKER_VERSION')) {
H A Dproduce_consume.phpt13 if (RD_KAFKA_VERSION >= 0x090000 && false !== getenv('TEST_KAFKA_BROKER_VERSION')) {
H A Dconf_callbacks_integration.phpt5 RD_KAFKA_VERSION >= 0x090000 || die("skip librdkafka too old");
H A Dmessage_headers.phpt5 RD_KAFKA_VERSION >= 0x000b04ff || die("skip librdkafka too old");
H A Dproduce_consume_queue.phpt15 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 Dcheck_features.c16 rd_kafka_version_str(), rd_kafka_version(), RD_KAFKA_VERSION); in main()
/dports/sysutils/rsyslog8/rsyslog-8.2112.0/plugins/imkafka/
H A Dimkafka.c414 #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 Domkafka.c760 #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

12