wuhao

icon company 北京万方软件 icon location beijing icon location Stay hungry, Stay young

Results 2 issues of wuhao

refresh relayFilter after relay changed

1 comment

If a client is configed to pull data from multi relays and these relays has diffrent id-source relationship,the client' partition thread may pull all partition's data from relay.That's because the...

skip endOfPeriodMarker in stream method

the windowOffset calculate method is diffrent between relay and client . Client filters the endOfPeriodMarker event as follows: if (e.isEndOfPeriodMarker()) { ... } else if (e.isCheckpointMessage()) { ... } else...