Re: Deep dive on the topic() streaming expression

[Hemant Purswani]

Thanks for the explanation, Joel.

I tried topic function today and it's working great. But I think it lacks
something that I will be needing for my use case. Currently, it returns
response in the following format. As you can see, it's not returning
topicId.


{ "result-set": { "docs": [ { "id": "123456", "_version_":
1553668767834177500 }, { "EOF": true, "RESPONSE_TIME": 81, "sleepMillis": 0
} ] } }

The way I was thinking of using it was to publish message on Kafka with
topicId and documentId, every time a document matches a query. And then on
my Kafka consumer side, I will get subscriber emails from DB using topicId
and email them subsequently.

Is it possible to implement such functionality using topic function?

Thanks,

Hemant