meteor
meteor copied to clipboard
Kafka sink raises error when `key_path` is specified in the config
Describe the bug Kafka sink fails to add key to its message due to changes in Metadata models. (Urn is now nested inside Resource)
To Reproduce Steps to reproduce the behavior:
- Create a recipe with kafka sink
- Set
key_pathvalue - Run recipe
- See error
Expected behavior
The recipe should be working properly with key_path and key should be published
Desktop (please complete the following information):
- OS: [e.g. macOS]
- Version [e.g. 10.15]