Hi Srikanth,
1) there is no support on DSL level, but if you use Processor API you
can do "anything" you like. So yes, a map-like transform() that gets
initialized with the "broadcast-side" of the join should work.
2) Right now, there is no way to stall a stream -- a custom
TimestampExtractor wil
This vote passes with 9 +1 votes (4 bindings) and no 0 or -1 votes.
+1 votes
PMC Members:
* Jay Kreps
* Jun Rao
* Guozhang Wang
* Joe Stein
Committers:
* Sriharsha Chintalapani
* Ewen Cheslack-Postava
Community:
* Dana Powers
* Vahid S. Hashemian
* Ashish Singh
Vote thread:https://www.mail-arc
Hi,
Does anyone know if this is a broker side implementation or consumer side?
We deal with long processing times of polls that caused rebalances and this
should fix our problem.
We will be upgrading our brokers to the 0.10.x branch long before upgrading
the consumers so just wanted to email this
