Skip to content

enhance: enable kafka for streaming

Codecov / codecov/patch failed Dec 22, 2024 in 1s

52.17% of diff hit (target 80.00%)

View this Pull Request on Codecov

52.17% of diff hit (target 80.00%)

Annotations

Check warning on line 738 in internal/querynodev2/delegator/delegator_data.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/querynodev2/delegator/delegator_data.go#L738

Added line #L738 was not covered by tests

Check warning on line 60 in pkg/streaming/util/message/adaptor/message_id.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/streaming/util/message/adaptor/message_id.go#L58-L60

Added lines #L58 - L60 were not covered by tests

Check warning on line 80 in pkg/streaming/util/message/adaptor/message_id.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/streaming/util/message/adaptor/message_id.go#L78-L80

Added lines #L78 - L80 were not covered by tests

Check warning on line 109 in pkg/util/paramtable/param_item.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/util/paramtable/param_item.go#L106-L109

Added lines #L106 - L109 were not covered by tests