feat: restore kafka #3033
feat: restore kafka #3033
No report found to compare against
View this Pull Request on Codecov
No report found to compare against
Annotations
Check warning on line 82 in extensions/impl/kafka/sink.go
codecov / codecov/patch
extensions/impl/kafka/sink.go#L82
Added line #L82 was not covered by tests
Check warning on line 136 in extensions/impl/kafka/sink.go
codecov / codecov/patch
extensions/impl/kafka/sink.go#L136
Added line #L136 was not covered by tests
Check warning on line 140 in extensions/impl/kafka/sink.go
codecov / codecov/patch
extensions/impl/kafka/sink.go#L139-L140
Added lines #L139 - L140 were not covered by tests
Check warning on line 147 in extensions/impl/kafka/sink.go
codecov / codecov/patch
extensions/impl/kafka/sink.go#L143-L147
Added lines #L143 - L147 were not covered by tests
Check warning on line 150 in extensions/impl/kafka/sink.go
codecov / codecov/patch
extensions/impl/kafka/sink.go#L150
Added line #L150 was not covered by tests
Check warning on line 156 in extensions/impl/kafka/sink.go
codecov / codecov/patch
extensions/impl/kafka/sink.go#L156
Added line #L156 was not covered by tests
Check warning on line 161 in extensions/impl/kafka/sink.go
codecov / codecov/patch
extensions/impl/kafka/sink.go#L161
Added line #L161 was not covered by tests
Check warning on line 172 in extensions/impl/kafka/sink.go
codecov / codecov/patch
extensions/impl/kafka/sink.go#L170-L172
Added lines #L170 - L172 were not covered by tests
Check warning on line 174 in extensions/impl/kafka/sink.go
codecov / codecov/patch
extensions/impl/kafka/sink.go#L174
Added line #L174 was not covered by tests
Check warning on line 178 in extensions/impl/kafka/sink.go
codecov / codecov/patch
extensions/impl/kafka/sink.go#L178
Added line #L178 was not covered by tests
Check warning on line 200 in extensions/impl/kafka/sink.go
codecov / codecov/patch
extensions/impl/kafka/sink.go#L198-L200
Added lines #L198 - L200 were not covered by tests
Check warning on line 212 in extensions/impl/kafka/sink.go
codecov / codecov/patch
extensions/impl/kafka/sink.go#L212
Added line #L212 was not covered by tests
Check warning on line 224 in extensions/impl/kafka/sink.go
codecov / codecov/patch
extensions/impl/kafka/sink.go#L221-L224
Added lines #L221 - L224 were not covered by tests
Check warning on line 227 in extensions/impl/kafka/sink.go
codecov / codecov/patch
extensions/impl/kafka/sink.go#L226-L227
Added lines #L226 - L227 were not covered by tests
Check warning on line 234 in extensions/impl/kafka/sink.go
codecov / codecov/patch
extensions/impl/kafka/sink.go#L229-L234
Added lines #L229 - L234 were not covered by tests
Check warning on line 236 in extensions/impl/kafka/sink.go
codecov / codecov/patch
extensions/impl/kafka/sink.go#L236
Added line #L236 was not covered by tests
Check warning on line 242 in extensions/impl/kafka/sink.go
codecov / codecov/patch
extensions/impl/kafka/sink.go#L241-L242
Added lines #L241 - L242 were not covered by tests
Check warning on line 81 in extensions/impl/kafka/source.go
codecov / codecov/patch
extensions/impl/kafka/source.go#L81
Added line #L81 was not covered by tests
Check warning on line 156 in extensions/impl/kafka/source.go
codecov / codecov/patch
extensions/impl/kafka/source.go#L156
Added line #L156 was not covered by tests
Check warning on line 166 in extensions/impl/kafka/source.go
codecov / codecov/patch
extensions/impl/kafka/source.go#L165-L166
Added lines #L165 - L166 were not covered by tests
Check warning on line 175 in extensions/impl/kafka/source.go
codecov / codecov/patch
extensions/impl/kafka/source.go#L169-L175
Added lines #L169 - L175 were not covered by tests
Check warning on line 180 in extensions/impl/kafka/source.go
codecov / codecov/patch
extensions/impl/kafka/source.go#L177-L180
Added lines #L177 - L180 were not covered by tests
Check warning on line 182 in extensions/impl/kafka/source.go
codecov / codecov/patch
extensions/impl/kafka/source.go#L182
Added line #L182 was not covered by tests
Check warning on line 185 in extensions/impl/kafka/source.go
codecov / codecov/patch
extensions/impl/kafka/source.go#L185
Added line #L185 was not covered by tests
Check warning on line 199 in extensions/impl/kafka/source.go
codecov / codecov/patch
extensions/impl/kafka/source.go#L188-L199
Added lines #L188 - L199 were not covered by tests