external/srs
1
0
Fork 0
mirror of https://github.com/ossrs/srs.git synced 2025-03-09 15:49:59 +00:00
Code Issues Releases Wiki Activity

add function to convert kafka array to vector

Browse source
This commit is contained in:
winlin 2015-10-22 12:15:30 +08:00
parent 84b3981d47
commit 33a015329d
4 changed files with 60 additions and 19 deletions
Download patch file Download diff file Expand all files Collapse all files

22
trunk/src/app/srs_app_kafka.cpp
View file

@ -34,6 +34,7 @@ using namespace std;
#include <srs_kernel_utility.hpp>
#include <srs_kernel_balance.hpp>
#include <srs_kafka_stack.hpp>
#include <srs_core_autofree.hpp>
#ifdef SRS_AUTO_KAFKA
@ -178,6 +179,14 @@ int SrsKafkaProducer::request_metadata()
srs_parse_endpoint(broker, server, port);
}
std::string topic = _srs_config->get_kafka_topic();
if (true) {
std::string senabled = srs_bool2switch(enabled);
std::string sbrokers = srs_join_vector_string(brokers->args, ",");
srs_trace("kafka request enabled:%s, brokers:%s, current:[%d]%s:%d, topic:%s",
senabled.c_str(), sbrokers.c_str(), lb->current(), server.c_str(), port, topic.c_str());
}
// connect to kafka server.
if ((ret = transport->connect(server, port, SRS_CONSTS_KAFKA_TIMEOUT_US)) != ERROR_SUCCESS) {
srs_error("kafka connect %s:%d failed. ret=%d", server.c_str(), port, ret);
@ -185,19 +194,12 @@ int SrsKafkaProducer::request_metadata()
}
// do fetch medata from broker.
std::string topic = _srs_config->get_kafka_topic();
if ((ret = kafka->fetch_metadata(topic)) != ERROR_SUCCESS) {
SrsKafkaTopicMetadataResponse* metadata = NULL;
if ((ret = kafka->fetch_metadata(topic, &metadata)) != ERROR_SUCCESS) {
srs_error("kafka fetch metadata failed. ret=%d", ret);
return ret;
}
// log when completed.
if (true) {
std::string senabled = srs_bool2switch(enabled);
std::string sbrokers = srs_join_vector_string(brokers->args, ",");
srs_trace("kafka ok, enabled:%s, brokers:%s, current:[%d]%s:%d, topic:%s",
senabled.c_str(), sbrokers.c_str(), lb->current(), server.c_str(), port, topic.c_str());
}
SrsAutoFree(SrsKafkaTopicMetadataResponse, metadata);
meatadata_ok = true;