merlimat commented on a change in pull request #1845: Functions schema
integration
URL: https://github.com/apache/incubator-pulsar/pull/1845#discussion_r191576650
##########
File path:
pulsar-client/src/main/java/org/apache/pulsar/client/api/ConsumerBuilder.java
##########
@@ -94,6 +94,11 @@
*/
ConsumerBuilder<T> topics(List<String> topicNames);
+ /**
+ *
+ */
+ ConsumerBuilder<T> addTopic(String topicName, Schema<T> schema);
Review comment:
> Multi-subscribe assumes that everything has a single schema (this may be a
flawed assumption)
I think that's an intuitive assumption:
* Consumer has a type
* It can consume from multiple topics.. as long as data has same format
To consume from different topics, with different types, we should just use
different consumer instances.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
