Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
feat: restore kafka #3033
feat: restore kafka #3033
Changes from 4 commits
6510d4c
e8f6de3
be44639
1c269ea
e20cbed
e89a32f
File filter
Filter by extension
Conversations
Jump to
There are no files selected for viewing
Check warning on line 82 in extensions/impl/kafka/sink.go
Codecov / codecov/patch
extensions/impl/kafka/sink.go#L82
Check warning on line 136 in extensions/impl/kafka/sink.go
Codecov / codecov/patch
extensions/impl/kafka/sink.go#L136
Check warning on line 140 in extensions/impl/kafka/sink.go
Codecov / codecov/patch
extensions/impl/kafka/sink.go#L139-L140
Check warning on line 147 in extensions/impl/kafka/sink.go
Codecov / codecov/patch
extensions/impl/kafka/sink.go#L143-L147
Check warning on line 150 in extensions/impl/kafka/sink.go
Codecov / codecov/patch
extensions/impl/kafka/sink.go#L150
Check warning on line 156 in extensions/impl/kafka/sink.go
Codecov / codecov/patch
extensions/impl/kafka/sink.go#L156
Check warning on line 161 in extensions/impl/kafka/sink.go
Codecov / codecov/patch
extensions/impl/kafka/sink.go#L161
Check warning on line 172 in extensions/impl/kafka/sink.go
Codecov / codecov/patch
extensions/impl/kafka/sink.go#L170-L172
Check warning on line 174 in extensions/impl/kafka/sink.go
Codecov / codecov/patch
extensions/impl/kafka/sink.go#L174
Check warning on line 178 in extensions/impl/kafka/sink.go
Codecov / codecov/patch
extensions/impl/kafka/sink.go#L178
Check warning on line 200 in extensions/impl/kafka/sink.go
Codecov / codecov/patch
extensions/impl/kafka/sink.go#L198-L200
Check warning on line 212 in extensions/impl/kafka/sink.go
Codecov / codecov/patch
extensions/impl/kafka/sink.go#L212
Check warning on line 224 in extensions/impl/kafka/sink.go
Codecov / codecov/patch
extensions/impl/kafka/sink.go#L221-L224
Check warning on line 227 in extensions/impl/kafka/sink.go
Codecov / codecov/patch
extensions/impl/kafka/sink.go#L226-L227
Check warning on line 234 in extensions/impl/kafka/sink.go
Codecov / codecov/patch
extensions/impl/kafka/sink.go#L229-L234
Check warning on line 236 in extensions/impl/kafka/sink.go
Codecov / codecov/patch
extensions/impl/kafka/sink.go#L236
Check warning on line 242 in extensions/impl/kafka/sink.go
Codecov / codecov/patch
extensions/impl/kafka/sink.go#L241-L242