Searched refs:sfacctd_counter_kafka_host (Results 1 – 3 of 3) sorted by relevance
119 extern struct p_kafka_host sfacctd_counter_kafka_host;
1326 time_t last_fail = P_broker_timers_get_last_fail(&sfacctd_counter_kafka_host.btimers); in main()1328 …last_fail && ((last_fail + P_broker_timers_get_retry_interval(&sfacctd_counter_kafka_host.btimers)… in main()2568 p_kafka_init_host(&sfacctd_counter_kafka_host, config.sfacctd_counter_kafka_config_file); in sfacctd_counter_init_kafka_host()2569 ret = p_kafka_connect_to_produce(&sfacctd_counter_kafka_host); in sfacctd_counter_init_kafka_host()2575 …p_kafka_set_broker(&sfacctd_counter_kafka_host, config.sfacctd_counter_kafka_broker_host, config.s… in sfacctd_counter_init_kafka_host()2576 p_kafka_set_topic(&sfacctd_counter_kafka_host, config.sfacctd_counter_kafka_topic); in sfacctd_counter_init_kafka_host()2577 p_kafka_set_partition(&sfacctd_counter_kafka_host, config.sfacctd_counter_kafka_partition); in sfacctd_counter_init_kafka_host()2578 …p_kafka_set_key(&sfacctd_counter_kafka_host, config.sfacctd_counter_kafka_partition_key, config.sf… in sfacctd_counter_init_kafka_host()2579 p_kafka_set_content_type(&sfacctd_counter_kafka_host, PM_KAFKA_CNT_TYPE_STR); in sfacctd_counter_init_kafka_host()2580 …P_broker_timers_set_retry_interval(&sfacctd_counter_kafka_host.btimers, config.sfacctd_counter_kaf… in sfacctd_counter_init_kafka_host()[all …]
34 struct p_kafka_host sfacctd_counter_kafka_host; variable