Home
last modified time | relevance | path

Searched refs:rd_kafka_broker_ApiVersion_supported (Results 1 – 18 of 18) sorted by relevance

/dports/net/librdkafka/librdkafka-1.8.2/src/
H A Drdkafka_request.c401 ApiVersion = rd_kafka_broker_ApiVersion_supported( in rd_kafka_FindCoordinatorRequest()
993 ApiVersion = rd_kafka_broker_ApiVersion_supported( in rd_kafka_OffsetFetchRequest()
1416 ApiVersion = rd_kafka_broker_ApiVersion_supported( in rd_kafka_OffsetDeleteRequest()
2287 ApiVersion = rd_kafka_broker_ApiVersion_supported( in rd_kafka_SaslHandshakeRequest()
3534 ApiVersion = rd_kafka_broker_ApiVersion_supported( in rd_kafka_CreateTopicsRequest()
3701 ApiVersion = rd_kafka_broker_ApiVersion_supported( in rd_kafka_DeleteTopicsRequest()
3770 ApiVersion = rd_kafka_broker_ApiVersion_supported( in rd_kafka_DeleteRecordsRequest()
3840 ApiVersion = rd_kafka_broker_ApiVersion_supported( in rd_kafka_CreatePartitionsRequest()
3947 ApiVersion = rd_kafka_broker_ApiVersion_supported( in rd_kafka_AlterConfigsRequest()
4059 ApiVersion = rd_kafka_broker_ApiVersion_supported( in rd_kafka_DescribeConfigsRequest()
[all …]
H A Drdkafka_broker.h396 int16_t rd_kafka_broker_ApiVersion_supported (rd_kafka_broker_t *rkb,
H A Drdkafka_msgset_writer.c147 (rd_kafka_broker_ApiVersion_supported( in rd_kafka_msgset_writer_select_MsgVersion()
201 msetw->msetw_ApiVersion = rd_kafka_broker_ApiVersion_supported( in rd_kafka_msgset_writer_select_MsgVersion()
H A Drdkafka_txnmgr.c1714 ApiVersion = rd_kafka_broker_ApiVersion_supported( in rd_kafka_txn_send_TxnOffsetCommitRequest()
H A Drdkafka_broker.c254 int16_t rd_kafka_broker_ApiVersion_supported (rd_kafka_broker_t *rkb, in rd_kafka_broker_ApiVersion_supported() function
4849 ApiVersion = rd_kafka_broker_ApiVersion_supported( in rd_kafka_broker_fetch_toppars()
H A Drdkafka_partition.c149 if (rd_kafka_broker_ApiVersion_supported(rktp->rktp_broker, in rd_kafka_toppar_consumer_lag_req()
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/
H A Drdkafka_request.c397 ApiVersion = rd_kafka_broker_ApiVersion_supported( in rd_kafka_FindCoordinatorRequest()
918 ApiVersion = rd_kafka_broker_ApiVersion_supported( in rd_kafka_OffsetFetchRequest()
1341 ApiVersion = rd_kafka_broker_ApiVersion_supported( in rd_kafka_OffsetDeleteRequest()
2282 ApiVersion = rd_kafka_broker_ApiVersion_supported( in rd_kafka_SaslHandshakeRequest()
3529 ApiVersion = rd_kafka_broker_ApiVersion_supported( in rd_kafka_CreateTopicsRequest()
3696 ApiVersion = rd_kafka_broker_ApiVersion_supported( in rd_kafka_DeleteTopicsRequest()
3765 ApiVersion = rd_kafka_broker_ApiVersion_supported( in rd_kafka_DeleteRecordsRequest()
3835 ApiVersion = rd_kafka_broker_ApiVersion_supported( in rd_kafka_CreatePartitionsRequest()
3942 ApiVersion = rd_kafka_broker_ApiVersion_supported( in rd_kafka_AlterConfigsRequest()
4054 ApiVersion = rd_kafka_broker_ApiVersion_supported( in rd_kafka_DescribeConfigsRequest()
[all …]
H A Drdkafka_broker.h396 int16_t rd_kafka_broker_ApiVersion_supported (rd_kafka_broker_t *rkb,
H A Drdkafka_msgset_writer.c147 (rd_kafka_broker_ApiVersion_supported( in rd_kafka_msgset_writer_select_MsgVersion()
201 msetw->msetw_ApiVersion = rd_kafka_broker_ApiVersion_supported( in rd_kafka_msgset_writer_select_MsgVersion()
H A Drdkafka_txnmgr.c1714 ApiVersion = rd_kafka_broker_ApiVersion_supported(
H A Drdkafka_broker.c248 int16_t rd_kafka_broker_ApiVersion_supported (rd_kafka_broker_t *rkb, in rd_kafka_broker_ApiVersion_supported() function
4794 ApiVersion = rd_kafka_broker_ApiVersion_supported( in rd_kafka_broker_fetch_toppars()
H A Drdkafka_partition.c149 if (rd_kafka_broker_ApiVersion_supported(rktp->rktp_broker, in rd_kafka_toppar_consumer_lag_req()
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/
H A Drdkafka_request.c344 ApiVersion = rd_kafka_broker_ApiVersion_supported( in rd_kafka_FindCoordinatorRequest()
2082 ApiVersion = rd_kafka_broker_ApiVersion_supported( in rd_kafka_SaslHandshakeRequest()
3317 ApiVersion = rd_kafka_broker_ApiVersion_supported( in rd_kafka_CreateTopicsRequest()
3462 ApiVersion = rd_kafka_broker_ApiVersion_supported( in rd_kafka_DeleteTopicsRequest()
3532 ApiVersion = rd_kafka_broker_ApiVersion_supported( in rd_kafka_CreatePartitionsRequest()
3639 ApiVersion = rd_kafka_broker_ApiVersion_supported( in rd_kafka_AlterConfigsRequest()
3751 ApiVersion = rd_kafka_broker_ApiVersion_supported( in rd_kafka_DescribeConfigsRequest()
3883 ApiVersion = rd_kafka_broker_ApiVersion_supported( in rd_kafka_InitProducerIdRequest()
3953 ApiVersion = rd_kafka_broker_ApiVersion_supported( in rd_kafka_AddPartitionsToTxnRequest()
4040 ApiVersion = rd_kafka_broker_ApiVersion_supported( in rd_kafka_AddOffsetsToTxnRequest()
[all …]
H A Drdkafka_broker.h392 int16_t rd_kafka_broker_ApiVersion_supported (rd_kafka_broker_t *rkb,
H A Drdkafka_msgset_writer.c147 (rd_kafka_broker_ApiVersion_supported( in rd_kafka_msgset_writer_select_MsgVersion()
201 msetw->msetw_ApiVersion = rd_kafka_broker_ApiVersion_supported( in rd_kafka_msgset_writer_select_MsgVersion()
H A Drdkafka_txnmgr.c1537 ApiVersion = rd_kafka_broker_ApiVersion_supported( in rd_kafka_txn_send_TxnOffsetCommitRequest()
H A Drdkafka_broker.c233 int16_t rd_kafka_broker_ApiVersion_supported (rd_kafka_broker_t *rkb, in rd_kafka_broker_ApiVersion_supported() function
4480 ApiVersion = rd_kafka_broker_ApiVersion_supported( in rd_kafka_broker_fetch_toppars()
H A Drdkafka_partition.c148 if (rd_kafka_broker_ApiVersion_supported(rktp->rktp_broker, in rd_kafka_toppar_consumer_lag_req()