Skip to content

enable source connector to set ForwardMessageProperty - #250

Merged
nlu90 merged 3 commits into
masterfrom
neng/source-forward-msg-property
Aug 11, 2021
Merged

enable source connector to set ForwardMessageProperty#250
nlu90 merged 3 commits into
masterfrom
neng/source-forward-msg-property

Conversation

@nlu90

@nlu90 nlu90 commented Aug 9, 2021

Copy link
Copy Markdown
Contributor

solves #249

@nlu90
nlu90 requested review from freeznet, sijie and tuteng August 9, 2021 15:59
Comment thread controllers/spec/utils.go Outdated
ProducerSpec: &producerSpec,
SerDeClassName: source.Spec.Output.SinkSerdeClassName,
SchemaType: source.Spec.Output.SinkSchemaType,
ForwardSourceMessageProperty: *source.Spec.ForwardSourceMessageProperty,

Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

The webhook is not available in tests, so ForwardSourceMessageProperty might be nil if not provided.

Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I thought I add a webhook for the check. Let me know if this helps

Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

yes, but the webhook is disabled by default, and needs some extra configs to make it work. I was working on that with #238, before the webhook is working, we can consider adding kubebuilder CRD validation markers.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants