kspp
kspp copied to clipboard
A high performance/ real-time C++ Kafka streams framework (C++17)
Hi all. While I know this isn’t an issue I don’t know where else to ask this. I am currently developing a Kafka application to stream live stock trading prices...
Sometimes there happens a call to `kafka_source_base::parse()` which is pure virtual. This patch moves initialization of `kafka_source::_thread` from `kafka_source_base` initializer list to a call `kafka_source_base::start()` when `kafka_source::thread_f()` is available.
Hi bitbouncer, I saw the librdkafka have Full Exactly-Once-Semantics (EOS) support. And I can not find any transaction code in kspp. So do you have any plan to involve the...