Searched refs:kafkap_kafka_host (Results 1 – 3 of 3) sorted by relevance
365 p_kafka_init_host(&kafkap_kafka_host, config.kafka_config_file); in kafka_cache_purge()381 p_kafka_init_topic_rr(&kafkap_kafka_host); in kafka_cache_purge()399 p_kafka_connect_to_produce(&kafkap_kafka_host); in kafka_cache_purge()445 …kafkap_kafka_host.sd_schema[AVRO_ACCT_DATA_SID] = compose_avro_schema_registry_name_2(p_kafka_get_… in kafka_cache_purge()449 …kafkap_kafka_host.sd_schema[AVRO_ACCT_INIT_SID] = compose_avro_schema_registry_name_2(p_kafka_get_… in kafka_cache_purge()453 …kafkap_kafka_host.sd_schema[AVRO_ACCT_CLOSE_SID] = compose_avro_schema_registry_name_2(p_kafka_get… in kafka_cache_purge()523 &p_avro_len, kafkap_kafka_host.errstr, sizeof(kafkap_kafka_host.errstr))) { in kafka_cache_purge()641 &p_avro_len, kafkap_kafka_host.errstr, sizeof(kafkap_kafka_host.errstr))) { in kafka_cache_purge()715 p_kafka_set_topic(&kafkap_kafka_host, dyn_kafka_topic); in kafka_cache_purge()849 &p_avro_len, kafkap_kafka_host.errstr, sizeof(kafkap_kafka_host.errstr))) { in kafka_cache_purge()[all …]
114 extern struct p_kafka_host kafkap_kafka_host;
29 struct p_kafka_host kafkap_kafka_host; variable