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
Several customers asked about having access to the Kafka message key and headers in the Cypher query Strategy.
In order to preserve backwards compatibility, we leave $event as-is and we'll inject two more parameters $eventKey and $eventHeaders
The text was updated successfully, but these errors were encountered:
@conker84 the general principle of "exposing to the cypher layer anything that the kafka client can deliver" is probably a good one. I can imagine valid use cases why a user would want this information, and Kafka is delivering it so why shouldn't they have it.
However there are probably going to be multiple different types of data about this. What I might suggest instead of $eventKey and $eventHeader is to inject a
Reason here is that $event is a very clean simple interface, but we don't want to spread the interface and add lots more things. It might be better to group them in one place for extensibility. In future or older versions of kafka what fields can be delivered and how they're named could change, so you don't want to couple our interface ($eventHeader cypher param) to a potentially changing kafka interface; rather give them $meta and then deliver with that just whatever extra bits of information about the event that Kafka will permit your client layer to inspect. In doing it this way, you can in our docs refer back to the kafka docs about "meta" information and just say "Hey, we're going to copy whatever is there with the same naming" and have a generally flexible interface that we're not responsible for maintaining, rather we just copy whatever the kafka client convention is.
Several customers asked about having access to the Kafka message key and headers in the Cypher query Strategy.
In order to preserve backwards compatibility, we leave
$event
as-is and we'll inject two more parameters$eventKey
and$eventHeaders
The text was updated successfully, but these errors were encountered: