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
Looking at this previous issue #130 and still think supporting SpEL in the topic name would be extremely useful. I've played around with the BinderAwareChannelResolver and using Routers to dynamically map to or create channels on the fly, however I feel that you should be able to maintain the MessageChannel abstraction from the underlying dynamic topic name.
My use case is the following, and having a dynamic topic name makes the most sense to me, however there may be an obvious alternative I am missing... if I am sharing my kafka cluster with multiple 'tenants', I may want to prepend my topic names with these tenant names... so 'orders' becomes 'tenant123_orders'.
From a Message Channel perspective, I would still like my channel to be named 'orders', since the resolved topic name is more of a kafka detail. If i created a Router (say TenantRouter), I would effectively be creating a new Channel for each one of these tenants, right?
Something like that following would be more convenient in my opinion: spring.cloud....orders.destination=${TenantResolver.getTenantId + '_orders'}
From @ngbalk on July 22, 2018 22:44
Looking at this previous issue #130 and still think supporting SpEL in the topic name would be extremely useful. I've played around with the
BinderAwareChannelResolver
and using Routers to dynamically map to or create channels on the fly, however I feel that you should be able to maintain the MessageChannel abstraction from the underlying dynamic topic name.My use case is the following, and having a dynamic topic name makes the most sense to me, however there may be an obvious alternative I am missing... if I am sharing my kafka cluster with multiple 'tenants', I may want to prepend my topic names with these tenant names... so 'orders' becomes 'tenant123_orders'.
From a Message Channel perspective, I would still like my channel to be named 'orders', since the resolved topic name is more of a kafka detail. If i created a Router (say
TenantRouter
), I would effectively be creating a new Channel for each one of these tenants, right?Something like that following would be more convenient in my opinion:
spring.cloud....orders.destination=${TenantResolver.getTenantId + '_orders'}
Copied from original issue: spring-cloud/spring-cloud-stream-binder-kafka#414
The text was updated successfully, but these errors were encountered: