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
I have a use case to read data from cluster (BootstrapServers) A, process the data and write it to a topic in cluster B. I'm not aware of any features that enable this behavior in the current implementation due to the use of a single StreamConfig object. Would it be possible to add this as a feature request, perhaps enabling overload to StreamBuilder.Stream() and StreamBuilder.Table() that take in a subset of the current configuration object.
The text was updated successfully, but these errors were encountered:
No for now this feature is not available because this library is designed to process data from Kafka to Kafka with a single cluster.
Technically it's possible but you loose the Exactly Once Semantics ..
Description
I have a use case to read data from cluster (
BootstrapServers
) A, process the data and write it to a topic in cluster B. I'm not aware of any features that enable this behavior in the current implementation due to the use of a singleStreamConfig
object. Would it be possible to add this as a feature request, perhaps enabling overload toStreamBuilder.Stream()
andStreamBuilder.Table()
that take in a subset of the current configuration object.The text was updated successfully, but these errors were encountered: