Skip to content

Commit

Permalink
Merge pull request #1149 from ripienaar/adr_44_metadata
Browse files Browse the repository at this point in the history
Remove adr-44 metadata from some more places
  • Loading branch information
ripienaar authored Sep 10, 2024
2 parents d49f316 + 76c5b30 commit 593be9e
Show file tree
Hide file tree
Showing 2 changed files with 8 additions and 0 deletions.
4 changes: 4 additions & 0 deletions cli/consumer_command.go
Original file line number Diff line number Diff line change
Expand Up @@ -1304,6 +1304,8 @@ func (c *consumerCmd) prepareConfig() (cfg *api.ConsumerConfig, err error) {
cfg.DeliverSubject = c.delivery
}

cfg.Metadata = iu.RemoveReservedMetadata(cfg.Metadata)

return cfg, err
}

Expand Down Expand Up @@ -1597,6 +1599,8 @@ func (c *consumerCmd) prepareConfig() (cfg *api.ConsumerConfig, err error) {
}
}

cfg.Metadata = iu.RemoveReservedMetadata(cfg.Metadata)

return cfg, nil
}

Expand Down
4 changes: 4 additions & 0 deletions cli/stream_command.go
Original file line number Diff line number Diff line change
Expand Up @@ -2349,6 +2349,8 @@ func (c *streamCmd) prepareConfig(_ *fisk.ParseContext, requireSize bool) api.St
cfg, err := c.loadConfigFile(c.inputFile)
fisk.FatalIfError(err, "invalid input")

cfg.Metadata = iu.RemoveReservedMetadata(cfg.Metadata)

if c.stream != "" {
cfg.Name = c.stream
}
Expand Down Expand Up @@ -2680,6 +2682,8 @@ func (c *streamCmd) prepareConfig(_ *fisk.ParseContext, requireSize bool) api.St
}
}

cfg.Metadata = iu.RemoveReservedMetadata(cfg.Metadata)

return cfg
}

Expand Down

0 comments on commit 593be9e

Please sign in to comment.