You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Hello there. I write an kStream consumer (connector). So I don't need the builder's output here. Just run it like KafkaStreams.start() does. Can it be added? Something simple, just like def start() = withProcessedDriver { _ => () }.
The text was updated successfully, but these errors were encountered:
Hello there. I write an kStream consumer (connector). So I don't need the builder's output here. Just run it like
KafkaStreams.start()
does. Can it be added? Something simple, just likedef start() = withProcessedDriver { _ => () }
.The text was updated successfully, but these errors were encountered: