juripetersen commented on PR #468: URL: https://github.com/apache/incubator-wayang/pull/468#issuecomment-2330763603
@kamir do you think that creating a `wayang-kafka` module inside of `wayang-platforms` would be a cleaner approach to add these operators? Right now it seems like you edit both `wayang-java` and `wayang-spark`, where both of them contain versions of operators from Kafka. I think conceptually, having all implementations for the specific apis in `wayang-kafka` would be neat. Then you could have `wayang-kafka/src/main/java/JavaKafkaOperator` `wayang-kafka/src/main/java/SparkKafkaOperator` etc and the respective platforms themselves don't have to concern about Kafka. What do you think? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
