Весенняя облачная кафка: RecordTooLargeException для производителя - PullRequest
Новая
       22

Весенняя облачная кафка: RecordTooLargeException для производителя

0 голосов
/ 05 июля 2018

Я уже немного об этом разбираюсь и наткнулся на множество разных статей и постов на эту тему. Из того, что я понял, мне нужно увеличить max.request.size по умолчанию 1000000.

Я могу увидеть кучу свойств на веб-сайте apache kafka , но они выглядят как свойства в файле .properties, но я использую .yml для своих свойств. Я не могу найти нигде, что есть примеры для этого

Я пробовал несколько разных способов (см. Ниже несколько примеров. Кто-нибудь сталкивался со статьями или постами о том, как их установить. yml файлов, или знаете, как это сделать? 

spring:  
  cloud:
    stream:
      kafka:
        bindings:           
          output:
            producer:
              max:
                request:
                  size: 5000000 


spring:  
  cloud:
    stream:
      kafka:
        binder:           
          max:
            request:
              size: 5000000
...