| /dports/net/librdkafka/librdkafka-1.8.2/tests/ |
| H A D | 0080-admin_ut.c | 204 options = rd_kafka_AdminOptions_new(rk, RD_KAFKA_ADMIN_OP_ANY); in do_test_CreateTopics()
315 options = rd_kafka_AdminOptions_new( in do_test_DeleteTopics()
419 options = rd_kafka_AdminOptions_new( in do_test_DeleteGroups()
537 options = rd_kafka_AdminOptions_new( in do_test_DeleteRecords()
645 options = rd_kafka_AdminOptions_new( in do_test_DeleteConsumerGroupOffsets()
839 options = rd_kafka_AdminOptions_new(rk, RD_KAFKA_ADMIN_OP_ANY); in do_test_configs()
993 options = rd_kafka_AdminOptions_new(rk, *for_api); in do_test_options()
1060 options = rd_kafka_AdminOptions_new(rk, (rd_kafka_admin_op_t)1234); in do_test_options()
|
| H A D | 0081-admin.c | 162 options = rd_kafka_AdminOptions_new( in do_test_CreateTopics()
354 options = rd_kafka_AdminOptions_new( in do_test_DeleteTopics()
611 options = rd_kafka_AdminOptions_new( in do_test_CreatePartitions()
823 options = rd_kafka_AdminOptions_new(rk, RD_KAFKA_ADMIN_OP_ALTERCONFIGS); in do_test_AlterConfigs()
1000 options = rd_kafka_AdminOptions_new(rk, RD_KAFKA_ADMIN_OP_ANY); in do_test_DescribeConfigs()
1205 options = rd_kafka_AdminOptions_new( in do_test_DeleteRecords()
1499 options = rd_kafka_AdminOptions_new( in do_test_DeleteGroups()
1673 options = rd_kafka_AdminOptions_new( in do_test_DeleteConsumerGroupOffsets()
|
| H A D | 0101-fetch-from-follower.cpp | 231 options = rd_kafka_AdminOptions_new(p->c_ptr(), RD_KAFKA_ADMIN_OP_ANY); in get_broker_rack_count()
|
| H A D | test.c | 4434 options = rd_kafka_AdminOptions_new(rk, RD_KAFKA_ADMIN_OP_CREATETOPICS); in test_admin_create_topic()
4550 options = rd_kafka_AdminOptions_new(rk, RD_KAFKA_ADMIN_OP_DELETETOPICS); in test_admin_delete_topic()
4638 options = rd_kafka_AdminOptions_new(rk, in test_admin_create_partitions()
5658 options = rd_kafka_AdminOptions_new(rk, RD_KAFKA_ADMIN_OP_CREATETOPICS); in test_CreateTopics_simple()
5726 options = rd_kafka_AdminOptions_new(rk, in test_CreatePartitions_simple()
5792 options = rd_kafka_AdminOptions_new(rk, RD_KAFKA_ADMIN_OP_DELETETOPICS); in test_DeleteTopics_simple()
5859 options = rd_kafka_AdminOptions_new(rk, RD_KAFKA_ADMIN_OP_DELETEGROUPS); in test_DeleteGroups_simple()
5915 options = rd_kafka_AdminOptions_new(rk, in test_DeleteRecords_simple()
5976 options = rd_kafka_AdminOptions_new( in test_DeleteConsumerGroupOffsets_simple()
6234 options = rd_kafka_AdminOptions_new(rk, RD_KAFKA_ADMIN_OP_DELETETOPICS); in test_delete_all_test_topics()
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/tests/ |
| H A D | 0080-admin_ut.c | 204 options = rd_kafka_AdminOptions_new(rk, RD_KAFKA_ADMIN_OP_ANY); in do_test_CreateTopics()
315 options = rd_kafka_AdminOptions_new( in do_test_DeleteTopics()
419 options = rd_kafka_AdminOptions_new( in do_test_DeleteGroups()
537 options = rd_kafka_AdminOptions_new( in do_test_DeleteRecords()
645 options = rd_kafka_AdminOptions_new( in do_test_DeleteConsumerGroupOffsets()
839 options = rd_kafka_AdminOptions_new(rk, RD_KAFKA_ADMIN_OP_ANY); in do_test_configs()
993 options = rd_kafka_AdminOptions_new(rk, *for_api); in do_test_options()
1060 options = rd_kafka_AdminOptions_new(rk, (rd_kafka_admin_op_t)1234); in do_test_options()
|
| H A D | 0081-admin.c | 162 options = rd_kafka_AdminOptions_new( in do_test_CreateTopics()
354 options = rd_kafka_AdminOptions_new( in do_test_DeleteTopics()
611 options = rd_kafka_AdminOptions_new( in do_test_CreatePartitions()
823 options = rd_kafka_AdminOptions_new(rk, RD_KAFKA_ADMIN_OP_ALTERCONFIGS); in do_test_AlterConfigs()
1000 options = rd_kafka_AdminOptions_new(rk, RD_KAFKA_ADMIN_OP_ANY); in do_test_DescribeConfigs()
1205 options = rd_kafka_AdminOptions_new( in do_test_DeleteRecords()
1499 options = rd_kafka_AdminOptions_new( in do_test_DeleteGroups()
1673 options = rd_kafka_AdminOptions_new( in do_test_DeleteConsumerGroupOffsets()
|
| H A D | test.c | 4392 options = rd_kafka_AdminOptions_new(rk, RD_KAFKA_ADMIN_OP_CREATETOPICS); in test_admin_create_topic()
4508 options = rd_kafka_AdminOptions_new(rk, RD_KAFKA_ADMIN_OP_DELETETOPICS); in test_admin_delete_topic()
4596 options = rd_kafka_AdminOptions_new(rk, in test_admin_create_partitions()
5616 options = rd_kafka_AdminOptions_new(rk, RD_KAFKA_ADMIN_OP_CREATETOPICS); in test_CreateTopics_simple()
5684 options = rd_kafka_AdminOptions_new(rk, in test_CreatePartitions_simple()
5750 options = rd_kafka_AdminOptions_new(rk, RD_KAFKA_ADMIN_OP_DELETETOPICS); in test_DeleteTopics_simple()
5817 options = rd_kafka_AdminOptions_new(rk, RD_KAFKA_ADMIN_OP_DELETEGROUPS); in test_DeleteGroups_simple()
5873 options = rd_kafka_AdminOptions_new(rk, in test_DeleteRecords_simple()
5934 options = rd_kafka_AdminOptions_new( in test_DeleteConsumerGroupOffsets_simple()
6192 options = rd_kafka_AdminOptions_new(rk, RD_KAFKA_ADMIN_OP_DELETETOPICS); in test_delete_all_test_topics()
|
| H A D | 0101-fetch-from-follower.cpp | 231 options = rd_kafka_AdminOptions_new(p->c_ptr(), RD_KAFKA_ADMIN_OP_ANY);
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/tests/ |
| H A D | 0080-admin_ut.c | 202 options = rd_kafka_AdminOptions_new(rk, RD_KAFKA_ADMIN_OP_ANY); in do_test_CreateTopics()
309 options = rd_kafka_AdminOptions_new( in do_test_DeleteTopics()
475 options = rd_kafka_AdminOptions_new(rk, RD_KAFKA_ADMIN_OP_ANY); in do_test_configs()
619 options = rd_kafka_AdminOptions_new(rk, *for_api); in do_test_options()
686 options = rd_kafka_AdminOptions_new(rk, (rd_kafka_admin_op_t)1234); in do_test_options()
|
| H A D | 0081-admin.c | 157 options = rd_kafka_AdminOptions_new( in do_test_CreateTopics()
344 options = rd_kafka_AdminOptions_new( in do_test_DeleteTopics()
596 options = rd_kafka_AdminOptions_new( in do_test_CreatePartitions()
798 options = rd_kafka_AdminOptions_new(rk, RD_KAFKA_ADMIN_OP_ALTERCONFIGS); in do_test_AlterConfigs()
970 options = rd_kafka_AdminOptions_new(rk, RD_KAFKA_ADMIN_OP_ANY); in do_test_DescribeConfigs()
|
| H A D | 0101-fetch-from-follower.cpp | 231 options = rd_kafka_AdminOptions_new(p->c_ptr(), RD_KAFKA_ADMIN_OP_ANY); in get_broker_rack_count()
|
| H A D | test.c | 3940 options = rd_kafka_AdminOptions_new(rk, RD_KAFKA_ADMIN_OP_CREATETOPICS); in test_admin_create_topic()
4056 options = rd_kafka_AdminOptions_new(rk, RD_KAFKA_ADMIN_OP_DELETETOPICS); in test_admin_delete_topic()
4144 options = rd_kafka_AdminOptions_new(rk, in test_admin_create_partitions()
5062 options = rd_kafka_AdminOptions_new(rk, RD_KAFKA_ADMIN_OP_CREATETOPICS); in test_CreateTopics_simple()
5130 options = rd_kafka_AdminOptions_new(rk, in test_CreatePartitions_simple()
5198 options = rd_kafka_AdminOptions_new(rk, RD_KAFKA_ADMIN_OP_DELETETOPICS); in test_DeleteTopics_simple()
5443 options = rd_kafka_AdminOptions_new(rk, RD_KAFKA_ADMIN_OP_DELETETOPICS); in test_delete_all_test_topics()
|
| /dports/net/librdkafka/librdkafka-1.8.2/examples/ |
| H A D | delete_records.c | 166 options = rd_kafka_AdminOptions_new(rk, in main()
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/examples/ |
| H A D | delete_records.c | 166 options = rd_kafka_AdminOptions_new(rk,
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-0.24.0/src/ |
| H A D | admin.rs | 452 NativeAdminOptions::from_ptr(rdsys::rd_kafka_AdminOptions_new( in to_native()
|
| /dports/net/py-confluent-kafka/confluent-kafka-1.2.0/confluent_kafka/src/ |
| H A D | Admin.c | 109 c_options = rd_kafka_AdminOptions_new(self->rk, for_api); in Admin_options_to_c()
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/ |
| H A D | rdkafka.h | 5583 rd_kafka_AdminOptions_new (rd_kafka_t *rk, rd_kafka_admin_op_t for_api);
|
| H A D | rdkafka_admin.c | 960 rd_kafka_AdminOptions_new (rd_kafka_t *rk, rd_kafka_admin_op_t for_api) { in rd_kafka_AdminOptions_new() function
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/src/ |
| H A D | bindings.rs | 1808 pub fn rd_kafka_AdminOptions_new( in rd_kafka_AdminOptions_new() function
|
| /dports/net/librdkafka/librdkafka-1.8.2/src/ |
| H A D | rdkafka.h | 6169 rd_kafka_AdminOptions_new (rd_kafka_t *rk, rd_kafka_admin_op_t for_api);
|
| H A D | rdkafka_admin.c | 1424 rd_kafka_AdminOptions_new (rd_kafka_t *rk, rd_kafka_admin_op_t for_api) { in rd_kafka_AdminOptions_new() function
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/ |
| H A D | rdkafka.h | 6163 rd_kafka_AdminOptions_new (rd_kafka_t *rk, rd_kafka_admin_op_t for_api);
|
| H A D | rdkafka_admin.c | 1415 rd_kafka_AdminOptions_new (rd_kafka_t *rk, rd_kafka_admin_op_t for_api) {
|