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
KafkaSinkSingle:
the destination_port is the same as the port used by `KafkaSource`. These ports must be unique as shotover and the destination kafka must be behind the same IP and therefore cannot share a port.
In order to implement this validation we will need to extend our transform validation infrastructure to pass in the TransformChainBuilder to the TransformBuilder::validate method so each transform may perform analysis on the rest of the chain.
The text was updated successfully, but these errors were encountered:
Since I originally wrote KafkaSinkSingle I've learnt that kafka has a far stronger distinction between advertised address and real address compared to cassandra.
So I think maybe the whole approach of including rewriting in the transform might have been a mistake.
Maybe we should just have kafka advertise shotover's address instead.
It should fail with a message like:
In order to implement this validation we will need to extend our transform validation infrastructure to pass in the TransformChainBuilder to the
TransformBuilder::validate
method so each transform may perform analysis on the rest of the chain.The text was updated successfully, but these errors were encountered: