Skip to content

Commit c67dd0c

Browse files
committed
[topic] fix build
1 parent 0a6b474 commit c67dd0c

File tree

2 files changed

+6
-3
lines changed

2 files changed

+6
-3
lines changed

CHANGELOG.md

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,6 @@
1+
## v3.34.3
2+
* Added missing options from topicservice
3+
14
## v3.34.2
25
* Added some description to error message from table pool get
36
* Moved implementation `sugar.GenerateDeclareSection` to `internal/table`

topic/topictypes/topictypes.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -71,10 +71,10 @@ func (c *Consumer) FromRaw(raw *rawtopic.Consumer) {
7171

7272
c.SupportedCodecs = make([]Codec, len(raw.SupportedCodecs))
7373
for index, codec := range raw.SupportedCodecs {
74-
c.SupportedCodecs[index] = codec
74+
c.SupportedCodecs[index] = Codec(codec)
7575
}
7676

77-
if !raw.ReadFrom.IsZero() {
77+
if raw.ReadFrom.HasValue {
7878
c.ReadFrom = raw.ReadFrom.Value
7979
}
8080
}
@@ -130,7 +130,7 @@ func (d *TopicDescription) FromRaw(raw *rawtopic.DescribeTopicResult) {
130130
d.PartitionSettings.FromRaw(&raw.PartitioningSettings)
131131

132132
d.Consumers = make([]Consumer, len(raw.Consumers))
133-
for i := 0; i < raw.Consumers; i++ {
133+
for i := 0; i < len(raw.Consumers); i++ {
134134
d.Consumers[i].FromRaw(&raw.Consumers[i])
135135
}
136136
}

0 commit comments

Comments
 (0)