| /dports/net/librdkafka/librdkafka-1.8.2/tests/ |
| H A D | testcpp.cpp | 44 RdKafka::Conf *topic_conf, in read_config_file() argument
77 r = topic_conf->set(n.substr(6), v, errstr); in read_config_file()
91 RdKafka::Conf **topic_conf, in conf_init() argument
97 if (topic_conf) in conf_init()
98 *topic_conf = RdKafka::Conf::create(RdKafka::Conf::CONF_TOPIC); in conf_init()
102 topic_conf ? *topic_conf : NULL, &timeout); in conf_init()
|
| H A D | 0011-produce_batch.c | 81 rd_kafka_topic_conf_t *topic_conf; in test_single_partition() local
90 test_conf_init(&conf, &topic_conf, 20); in test_single_partition()
102 topic_conf); in test_single_partition()
203 rd_kafka_topic_conf_t *topic_conf; in test_partitioner() local
210 test_conf_init(&conf, &topic_conf, 30); in test_partitioner()
222 topic_conf); in test_partitioner()
318 rd_kafka_topic_conf_t *topic_conf; in test_per_message_partition_flag() local
327 test_conf_init(&conf, &topic_conf, 30); in test_per_message_partition_flag()
341 topic_conf); in test_per_message_partition_flag()
452 rd_kafka_topic_conf_t *topic_conf; in test_message_partitioner_wo_per_message_flag() local
[all …]
|
| H A D | 0013-null-msgs.c | 71 rd_kafka_topic_conf_t *topic_conf; in produce_null_messages() local
77 test_conf_init(&conf, &topic_conf, 20); in produce_null_messages()
83 rd_kafka_topic_conf_set(topic_conf, "request.required.acks", "-1", in produce_null_messages()
89 rkt = rd_kafka_topic_new(rk, topic, topic_conf); in produce_null_messages()
274 rd_kafka_topic_conf_t *topic_conf; in consume_messages() local
277 test_conf_init(&conf, &topic_conf, 20); in consume_messages()
282 rkt = rd_kafka_topic_new(rk, topic, topic_conf); in consume_messages()
333 rd_kafka_topic_conf_t *topic_conf; in consume_messages_with_queues() local
339 test_conf_init(&conf, &topic_conf, 20); in consume_messages_with_queues()
348 rkt = rd_kafka_topic_new(rk, topic, topic_conf); in consume_messages_with_queues()
|
| H A D | 0012-produce_consume.c | 73 rd_kafka_topic_conf_t *topic_conf; in produce_messages() local
82 test_conf_init(&conf, &topic_conf, 20); in produce_messages()
88 rd_kafka_topic_conf_set(topic_conf, "request.required.acks", "-1", in produce_messages()
94 rkt = rd_kafka_topic_new(rk, topic, topic_conf); in produce_messages()
307 rd_kafka_topic_conf_t *topic_conf; in consume_messages() local
310 test_conf_init(&conf, &topic_conf, 20); in consume_messages()
317 rkt = rd_kafka_topic_new(rk, topic, topic_conf); in consume_messages()
376 rd_kafka_topic_conf_t *topic_conf; in consume_messages_with_queues() local
382 test_conf_init(&conf, &topic_conf, 20); in consume_messages_with_queues()
393 rkt = rd_kafka_topic_new(rk, topic, topic_conf); in consume_messages_with_queues()
|
| H A D | 0014-reconsume-191.c | 66 rd_kafka_topic_conf_t *topic_conf; in produce_messages() local
72 test_conf_init(&conf, &topic_conf, 20); in produce_messages()
78 rd_kafka_topic_conf_set(topic_conf, "request.required.acks", "-1", in produce_messages()
84 rkt = rd_kafka_topic_new(rk, topic, topic_conf); in produce_messages()
331 rd_kafka_topic_conf_t *topic_conf; in consume_messages_callback_multi() local
339 test_conf_init(&conf, &topic_conf, 20); in consume_messages_callback_multi()
341 test_topic_conf_set(topic_conf, "offset.store.method", in consume_messages_callback_multi()
354 rd_kafka_topic_conf_set(topic_conf, "auto.offset.reset", "smallest", in consume_messages_callback_multi()
357 rkt = rd_kafka_topic_new(rk, topic, topic_conf); in consume_messages_callback_multi()
|
| H A D | 0008-reqacks.c | 81 rd_kafka_topic_conf_t *topic_conf; in main_0008_reqacks() local
101 test_conf_init(&conf, &topic_conf, 10); in main_0008_reqacks()
111 if (rd_kafka_topic_conf_set(topic_conf, "request.required.acks", in main_0008_reqacks()
131 rkt = rd_kafka_topic_new(rk, topic, topic_conf); in main_0008_reqacks()
|
| H A D | 0001-multiobj.c | 53 rd_kafka_topic_conf_t *topic_conf; in main_0001_multiobj() local
57 test_conf_init(&conf, &topic_conf, 30); in main_0001_multiobj()
65 rkt = rd_kafka_topic_new(rk, topic, topic_conf); in main_0001_multiobj()
|
| H A D | 0007-autotopic.c | 77 rd_kafka_topic_conf_t *topic_conf; in main_0007_autotopic() local
83 test_conf_init(&conf, &topic_conf, 10); in main_0007_autotopic()
96 topic_conf); in main_0007_autotopic()
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/tests/ |
| H A D | testcpp.cpp | 44 RdKafka::Conf *topic_conf, in read_config_file() argument
77 r = topic_conf->set(n.substr(6), v, errstr); in read_config_file()
91 RdKafka::Conf **topic_conf, in conf_init() argument
97 if (topic_conf) in conf_init()
98 *topic_conf = RdKafka::Conf::create(RdKafka::Conf::CONF_TOPIC); in conf_init()
102 topic_conf ? *topic_conf : NULL, &timeout); in conf_init()
|
| H A D | 0011-produce_batch.c | 81 rd_kafka_topic_conf_t *topic_conf; in test_single_partition() local
90 test_conf_init(&conf, &topic_conf, 20); in test_single_partition()
102 topic_conf); in test_single_partition()
203 rd_kafka_topic_conf_t *topic_conf; in test_partitioner() local
210 test_conf_init(&conf, &topic_conf, 30); in test_partitioner()
222 topic_conf); in test_partitioner()
318 rd_kafka_topic_conf_t *topic_conf; in test_per_message_partition_flag() local
327 test_conf_init(&conf, &topic_conf, 30); in test_per_message_partition_flag()
341 topic_conf); in test_per_message_partition_flag()
452 rd_kafka_topic_conf_t *topic_conf; in test_message_partitioner_wo_per_message_flag() local
[all …]
|
| H A D | 0013-null-msgs.c | 71 rd_kafka_topic_conf_t *topic_conf; in produce_null_messages() local
77 test_conf_init(&conf, &topic_conf, 20); in produce_null_messages()
83 rd_kafka_topic_conf_set(topic_conf, "request.required.acks", "-1", in produce_null_messages()
89 rkt = rd_kafka_topic_new(rk, topic, topic_conf); in produce_null_messages()
274 rd_kafka_topic_conf_t *topic_conf; in consume_messages() local
277 test_conf_init(&conf, &topic_conf, 20); in consume_messages()
282 rkt = rd_kafka_topic_new(rk, topic, topic_conf); in consume_messages()
333 rd_kafka_topic_conf_t *topic_conf; in consume_messages_with_queues() local
339 test_conf_init(&conf, &topic_conf, 20); in consume_messages_with_queues()
348 rkt = rd_kafka_topic_new(rk, topic, topic_conf); in consume_messages_with_queues()
|
| H A D | 0012-produce_consume.c | 73 rd_kafka_topic_conf_t *topic_conf; in produce_messages() local
82 test_conf_init(&conf, &topic_conf, 20); in produce_messages()
88 rd_kafka_topic_conf_set(topic_conf, "request.required.acks", "-1", in produce_messages()
94 rkt = rd_kafka_topic_new(rk, topic, topic_conf); in produce_messages()
307 rd_kafka_topic_conf_t *topic_conf; in consume_messages() local
310 test_conf_init(&conf, &topic_conf, 20); in consume_messages()
317 rkt = rd_kafka_topic_new(rk, topic, topic_conf); in consume_messages()
376 rd_kafka_topic_conf_t *topic_conf; in consume_messages_with_queues() local
382 test_conf_init(&conf, &topic_conf, 20); in consume_messages_with_queues()
393 rkt = rd_kafka_topic_new(rk, topic, topic_conf); in consume_messages_with_queues()
|
| H A D | 0014-reconsume-191.c | 66 rd_kafka_topic_conf_t *topic_conf; in produce_messages() local
72 test_conf_init(&conf, &topic_conf, 20); in produce_messages()
78 rd_kafka_topic_conf_set(topic_conf, "request.required.acks", "-1", in produce_messages()
84 rkt = rd_kafka_topic_new(rk, topic, topic_conf); in produce_messages()
331 rd_kafka_topic_conf_t *topic_conf; in consume_messages_callback_multi() local
339 test_conf_init(&conf, &topic_conf, 20); in consume_messages_callback_multi()
341 test_topic_conf_set(topic_conf, "offset.store.method", in consume_messages_callback_multi()
354 rd_kafka_topic_conf_set(topic_conf, "auto.offset.reset", "smallest", in consume_messages_callback_multi()
357 rkt = rd_kafka_topic_new(rk, topic, topic_conf); in consume_messages_callback_multi()
|
| H A D | 0008-reqacks.c | 81 rd_kafka_topic_conf_t *topic_conf; in main_0008_reqacks() local
101 test_conf_init(&conf, &topic_conf, 10); in main_0008_reqacks()
111 if (rd_kafka_topic_conf_set(topic_conf, "request.required.acks", in main_0008_reqacks()
131 rkt = rd_kafka_topic_new(rk, topic, topic_conf); in main_0008_reqacks()
|
| H A D | 0001-multiobj.c | 53 rd_kafka_topic_conf_t *topic_conf; in main_0001_multiobj() local
57 test_conf_init(&conf, &topic_conf, 30); in main_0001_multiobj()
65 rkt = rd_kafka_topic_new(rk, topic, topic_conf); in main_0001_multiobj()
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/tests/ |
| H A D | testcpp.cpp | 44 RdKafka::Conf *topic_conf, in read_config_file() argument
77 r = topic_conf->set(n.substr(6), v, errstr); in read_config_file()
91 RdKafka::Conf **topic_conf, in conf_init() argument
97 if (topic_conf) in conf_init()
98 *topic_conf = RdKafka::Conf::create(RdKafka::Conf::CONF_TOPIC); in conf_init()
102 topic_conf ? *topic_conf : NULL, &timeout); in conf_init()
|
| H A D | 0011-produce_batch.c | 81 rd_kafka_topic_conf_t *topic_conf; in test_single_partition() local
90 test_conf_init(&conf, &topic_conf, 20); in test_single_partition()
102 topic_conf); in test_single_partition()
203 rd_kafka_topic_conf_t *topic_conf; in test_partitioner() local
210 test_conf_init(&conf, &topic_conf, 30); in test_partitioner()
222 topic_conf); in test_partitioner()
318 rd_kafka_topic_conf_t *topic_conf; in test_per_message_partition_flag() local
327 test_conf_init(&conf, &topic_conf, 30); in test_per_message_partition_flag()
341 topic_conf); in test_per_message_partition_flag()
452 rd_kafka_topic_conf_t *topic_conf; in test_message_partitioner_wo_per_message_flag() local
[all …]
|
| H A D | 0013-null-msgs.c | 71 rd_kafka_topic_conf_t *topic_conf; in produce_null_messages() local
77 test_conf_init(&conf, &topic_conf, 20); in produce_null_messages()
83 rd_kafka_topic_conf_set(topic_conf, "request.required.acks", "-1", in produce_null_messages()
89 rkt = rd_kafka_topic_new(rk, topic, topic_conf); in produce_null_messages()
274 rd_kafka_topic_conf_t *topic_conf; in consume_messages() local
277 test_conf_init(&conf, &topic_conf, 20); in consume_messages()
282 rkt = rd_kafka_topic_new(rk, topic, topic_conf); in consume_messages()
333 rd_kafka_topic_conf_t *topic_conf; in consume_messages_with_queues() local
339 test_conf_init(&conf, &topic_conf, 20); in consume_messages_with_queues()
348 rkt = rd_kafka_topic_new(rk, topic, topic_conf); in consume_messages_with_queues()
|
| H A D | 0012-produce_consume.c | 73 rd_kafka_topic_conf_t *topic_conf; in produce_messages() local
82 test_conf_init(&conf, &topic_conf, 20); in produce_messages()
88 rd_kafka_topic_conf_set(topic_conf, "request.required.acks", "-1", in produce_messages()
94 rkt = rd_kafka_topic_new(rk, topic, topic_conf); in produce_messages()
307 rd_kafka_topic_conf_t *topic_conf; in consume_messages() local
310 test_conf_init(&conf, &topic_conf, 20); in consume_messages()
317 rkt = rd_kafka_topic_new(rk, topic, topic_conf); in consume_messages()
376 rd_kafka_topic_conf_t *topic_conf; in consume_messages_with_queues() local
382 test_conf_init(&conf, &topic_conf, 20); in consume_messages_with_queues()
393 rkt = rd_kafka_topic_new(rk, topic, topic_conf); in consume_messages_with_queues()
|
| H A D | 0014-reconsume-191.c | 66 rd_kafka_topic_conf_t *topic_conf;
72 test_conf_init(&conf, &topic_conf, 20);
78 rd_kafka_topic_conf_set(topic_conf, "request.required.acks", "-1",
84 rkt = rd_kafka_topic_new(rk, topic, topic_conf);
331 rd_kafka_topic_conf_t *topic_conf;
339 test_conf_init(&conf, &topic_conf, 20);
341 test_topic_conf_set(topic_conf, "offset.store.method",
354 rd_kafka_topic_conf_set(topic_conf, "auto.offset.reset", "smallest",
357 rkt = rd_kafka_topic_new(rk, topic, topic_conf);
|
| H A D | 0008-reqacks.c | 81 rd_kafka_topic_conf_t *topic_conf; in main_0008_reqacks() local
101 test_conf_init(&conf, &topic_conf, 10); in main_0008_reqacks()
111 if (rd_kafka_topic_conf_set(topic_conf, "request.required.acks", in main_0008_reqacks()
131 rkt = rd_kafka_topic_new(rk, topic, topic_conf); in main_0008_reqacks()
|
| H A D | 0001-multiobj.c | 53 rd_kafka_topic_conf_t *topic_conf; in main_0001_multiobj() local
57 test_conf_init(&conf, &topic_conf, 30); in main_0001_multiobj()
65 rkt = rd_kafka_topic_new(rk, topic, topic_conf); in main_0001_multiobj()
|
| /dports/net/librdkafka/librdkafka-1.8.2/examples/ |
| H A D | rdkafka_example.c | 296 rd_kafka_topic_conf_t *topic_conf; in main() local
318 topic_conf = rd_kafka_topic_conf_new(); in main()
437 topic_conf, in main()
464 res = rd_kafka_topic_conf_set(topic_conf, in main()
501 arr = rd_kafka_topic_conf_dump(topic_conf, in main()
608 rkt = rd_kafka_topic_new(rk, topic, topic_conf); in main()
609 topic_conf = NULL; /* Now owned by topic */ in main()
730 rkt = rd_kafka_topic_new(rk, topic, topic_conf); in main()
835 if (topic_conf) in main()
847 if (topic_conf) in main()
[all …]
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/examples/ |
| H A D | rdkafka_example.c | 290 rd_kafka_topic_conf_t *topic_conf; in main() local
312 topic_conf = rd_kafka_topic_conf_new(); in main()
431 topic_conf, in main()
458 res = rd_kafka_topic_conf_set(topic_conf, in main()
495 arr = rd_kafka_topic_conf_dump(topic_conf, in main()
600 rkt = rd_kafka_topic_new(rk, topic, topic_conf); in main()
601 topic_conf = NULL; /* Now owned by topic */ in main()
729 rkt = rd_kafka_topic_new(rk, topic, topic_conf); in main()
841 if (topic_conf) in main()
853 if (topic_conf) in main()
[all …]
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/examples/ |
| H A D | rdkafka_example.c | 296 rd_kafka_topic_conf_t *topic_conf; in main() local
318 topic_conf = rd_kafka_topic_conf_new(); in main()
437 topic_conf, in main()
464 res = rd_kafka_topic_conf_set(topic_conf, in main()
501 arr = rd_kafka_topic_conf_dump(topic_conf, in main()
608 rkt = rd_kafka_topic_new(rk, topic, topic_conf); in main()
609 topic_conf = NULL; /* Now owned by topic */ in main()
730 rkt = rd_kafka_topic_new(rk, topic, topic_conf); in main()
835 if (topic_conf) in main()
847 if (topic_conf) in main()
[all …]
|