Skip to content

Commit

Permalink
fix merge conflicts
Browse files Browse the repository at this point in the history
Signed-off-by: Saketh kappala <[email protected]>
  • Loading branch information
sappusaketh committed Apr 19, 2024
1 parent 8c89a78 commit 505c92f
Showing 1 changed file with 0 additions and 4 deletions.
4 changes: 0 additions & 4 deletions plugin/storage/kafka/options.go
Original file line number Diff line number Diff line change
Expand Up @@ -157,11 +157,7 @@ func (opt *Options) AddFlags(flagSet *flag.FlagSet) {
flagSet.Int(
configPrefix+suffixMaxMessageBytes,
defaultMaxMessageBytes,
<<<<<<< HEAD
"(experimental) The maximum permitted size of a message. Should be set equal to or smaller than the broker's `message.max.bytes`.",
=======
"(experimental) The maximum permitted size of a message (defaults to 1000000). Should be set equal to or smaller than the broker's `message.max.bytes`.",
>>>>>>> 33dd2306 (Add support for setting max message bytes config)
)
flagSet.String(
configPrefix+suffixBrokers,
Expand Down

0 comments on commit 505c92f

Please sign in to comment.