Defined in File kafka_source.cpp
-
template<bool EnableFilter>
std::string morpheus::concat_message_batch(std::vector<std::unique_ptr<RdKafka::Message>> const &message_batch)
Template Function morpheus::concat_message_batch
Previous
Enum TypeId
Next
Template Function morpheus::detail::set_contiguous_stride