Skip to content
This repository has been archived by the owner on Jan 24, 2024. It is now read-only.

[improve] Add message.max.bytes for describe broker config #1776

Conversation

Demogorgon314
Copy link
Member

Motivation

Some of the Producer requires the message.max.bytes configuration.

Error: [CDC:ErrKafkaNewSaramaProducer]new sarama producer: [CDC:ErrKafkaBrokerConfigNotFound]cannot find the `message.max.bytes` from the broker's configuration

Modifications

  • Add message.max.bytes for describe broker config. The config is reused pulsar config.

Documentation

Check the box below.

Need to update docs?

  • doc-required

    (If you need help on updating docs, create a doc issue)

  • no-need-doc

    (Please explain why)

  • doc

    (If this PR contains doc changes)

@Demogorgon314 Demogorgon314 self-assigned this Mar 23, 2023
@github-actions github-actions bot added the no-need-doc This pr does not need any document label Mar 23, 2023
@codecov
Copy link

codecov bot commented Mar 23, 2023

Codecov Report

Merging #1776 (692a12e) into master (7faa3f4) will decrease coverage by 0.04%.
The diff coverage is 0.00%.

Impacted file tree graph

@@             Coverage Diff              @@
##             master    #1776      +/-   ##
============================================
- Coverage     16.05%   16.02%   -0.04%     
  Complexity      626      626              
============================================
  Files           165      165              
  Lines         12311    12336      +25     
  Branches       1128     1128              
============================================
  Hits           1977     1977              
- Misses        10171    10196      +25     
  Partials        163      163              
Impacted Files Coverage Δ
...streamnative/pulsar/handlers/kop/AdminManager.java 0.40% <0.00%> (-0.01%) ⬇️
...ative/pulsar/handlers/kop/KafkaCommandDecoder.java 0.33% <0.00%> (-0.02%) ⬇️
...ative/pulsar/handlers/kop/KafkaRequestHandler.java 1.08% <0.00%> (-0.01%) ⬇️

@BewareMyPower BewareMyPower merged commit 92285f1 into streamnative:master Mar 23, 2023
7 of 9 checks passed
@Demogorgon314 Demogorgon314 deleted the Demogorgon314/add-mesage-max-size branch March 23, 2023 07:43
BewareMyPower pushed a commit that referenced this pull request Mar 28, 2023
### Motivation

Some of the Producer requires the `message.max.bytes` configuration.
```
Error: [CDC:ErrKafkaNewSaramaProducer]new sarama producer: [CDC:ErrKafkaBrokerConfigNotFound]cannot find the `message.max.bytes` from the broker's configuration

```

### Modifications

* Add `message.max.bytes` for describe broker config. The config is
reused pulsar config.

(cherry picked from commit 92285f1)
Demogorgon314 added a commit that referenced this pull request Apr 4, 2023
### Motivation

Some of the Producer requires the `message.max.bytes` configuration.
```
Error: [CDC:ErrKafkaNewSaramaProducer]new sarama producer: [CDC:ErrKafkaBrokerConfigNotFound]cannot find the `message.max.bytes` from the broker's configuration

```

### Modifications

* Add `message.max.bytes` for describe broker config. The config is
reused pulsar config.

(cherry picked from commit 92285f1)
Demogorgon314 added a commit that referenced this pull request Apr 6, 2023
### Motivation

Some of the Producer requires the `message.max.bytes` configuration.
```
Error: [CDC:ErrKafkaNewSaramaProducer]new sarama producer: [CDC:ErrKafkaBrokerConfigNotFound]cannot find the `message.max.bytes` from the broker's configuration

```

### Modifications

* Add `message.max.bytes` for describe broker config. The config is
reused pulsar config.

(cherry picked from commit 92285f1)
Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Projects
None yet
Development

Successfully merging this pull request may close these issues.

None yet

2 participants