Skip to content

fix(#234): use unique consumer groups

Codecov / codecov/patch failed Nov 28, 2023 in 1s

43.98% of diff hit (target 61.08%)

View this Pull Request on Codecov

43.98% of diff hit (target 61.08%)

Annotations

Check warning on line 43 in internal/repository/cache/cache.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/repository/cache/cache.go#L42-L43

Added lines #L42 - L43 were not covered by tests

Check warning on line 52 in internal/repository/cache/cache.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/repository/cache/cache.go#L50-L52

Added lines #L50 - L52 were not covered by tests

Check warning on line 95 in internal/repository/cache/cache.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/repository/cache/cache.go#L81-L95

Added lines #L81 - L95 were not covered by tests

Check warning on line 26 in internal/repository/cache/lowlevel.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/repository/cache/lowlevel.go#L22-L26

Added lines #L22 - L26 were not covered by tests

Check warning on line 37 in internal/repository/cache/lowlevel.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/repository/cache/lowlevel.go#L33-L37

Added lines #L33 - L37 were not covered by tests

Check warning on line 40 in internal/repository/cache/lowlevel.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/repository/cache/lowlevel.go#L39-L40

Added lines #L39 - L40 were not covered by tests

Check warning on line 51 in internal/repository/cache/lowlevel.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/repository/cache/lowlevel.go#L47-L51

Added lines #L47 - L51 were not covered by tests

Check warning on line 64 in internal/repository/cache/lowlevel.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/repository/cache/lowlevel.go#L59-L64

Added lines #L59 - L64 were not covered by tests

Check warning on line 83 in internal/repository/cache/lowlevel.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/repository/cache/lowlevel.go#L79-L83

Added lines #L79 - L83 were not covered by tests

Check warning on line 94 in internal/repository/cache/lowlevel.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/repository/cache/lowlevel.go#L90-L94

Added lines #L90 - L94 were not covered by tests

Check warning on line 167 in internal/repository/config/accessors.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/repository/config/accessors.go#L166-L167

Added lines #L166 - L167 were not covered by tests

Check warning on line 175 in internal/repository/config/accessors.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/repository/config/accessors.go#L174-L175

Added lines #L174 - L175 were not covered by tests

Check warning on line 57 in internal/repository/kafka/kafka.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/repository/kafka/kafka.go#L56-L57

Added lines #L56 - L57 were not covered by tests

Check warning on line 61 in internal/repository/kafka/kafka.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/repository/kafka/kafka.go#L61

Added line #L61 was not covered by tests

Check warning on line 69 in internal/repository/kafka/kafka.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/repository/kafka/kafka.go#L69

Added line #L69 was not covered by tests

Check warning on line 84 in internal/repository/kafka/kafka.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/repository/kafka/kafka.go#L84

Added line #L84 was not covered by tests

Check warning on line 94 in internal/repository/kafka/kafka.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/repository/kafka/kafka.go#L87-L94

Added lines #L87 - L94 were not covered by tests

Check warning on line 98 in internal/repository/kafka/kafka.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/repository/kafka/kafka.go#L97-L98

Added lines #L97 - L98 were not covered by tests

Check warning on line 106 in internal/repository/kafka/kafka.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/repository/kafka/kafka.go#L101-L106

Added lines #L101 - L106 were not covered by tests

Check warning on line 116 in internal/repository/kafka/kafka.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/repository/kafka/kafka.go#L110-L116

Added lines #L110 - L116 were not covered by tests

Check warning on line 119 in internal/repository/kafka/kafka.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/repository/kafka/kafka.go#L118-L119

Added lines #L118 - L119 were not covered by tests

Check warning on line 127 in internal/repository/kafka/kafka.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/repository/kafka/kafka.go#L127

Added line #L127 was not covered by tests

Check warning on line 132 in internal/repository/kafka/kafka.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/repository/kafka/kafka.go#L132

Added line #L132 was not covered by tests

Check warning on line 135 in internal/repository/kafka/kafka.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/repository/kafka/kafka.go#L135

Added line #L135 was not covered by tests

Check warning on line 137 in internal/repository/kafka/kafka.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/repository/kafka/kafka.go#L137

Added line #L137 was not covered by tests