Блог

Я пытаюсь установить другой akka.http.parsing.max-chunk-size

Мой application.conf находится в src/resources/ и выглядит так:

 akka.http {
   parsing {
       max-chunk-size=20m
   }
}
  

Я использую этот код в своем основном для настройки своей системы:

 val conf = ConfigFactory.load()
implicit val system = ActorSystem()
implicit val materializer = ActorMaterializer() 
implicit val executionContext = system.dispatcher
  

Однако я все еще получаю эту ошибку при попытке сделать большой запрос get:

 akka.http.scaladsl.model.EntityStreamException: HTTP chunk size exceeds the configured limit of 1048576 bytes
  

РЕДАКТИРОВАТЬ: я попытался переместить файл на основе полученного ответа, однако я все равно получаю ту же ошибку. Моя структура программы выглядит следующим образом:

 ├── main
│   ├── resources
│   │   └── application.conf
│   └── scala
│       ├── program
│       │   ├── BackTester.scala
│       │   ├── Main.scala
│       │   └── StrategyExecutor.scala
│       ├── strategies
│       │   ├── BollingerBandStrategy.scala
│       │   ├── CrossingSMAStrategy.scala
│       │   ├── RSIStrategy.scala
│       │   ├── StochasticStrategy.scala
│       │   └── TradingStrategies.scala
│       └── util
│           ├── Interval.scala
│           ├── JsonParser.scala
│           ├── Time.scala
│           ├── barseries
│           │   └── barSeriesBuilder.scala
│           └── requests
│               └── Fetcher.scala
└── test
    └── scala
  

Я посмотрел на официальный сайт, и похоже, что конфигурация правильная ( https://doc.akka.io/docs/akka-http/current/configuration.html ). Я бы поместил внутри конкретного приложения в файл application.conf. Как этот пример здесь ниже.

 routersDemo {
  akka {
    actor.deployment {
      /poolMaster2 {
        router = round-robin-pool
        nr-of-instances = 5
      }

      /groupMaster2 {
        router = round-robin-group
        routees {
          paths = ["/user/slave_1","/user/slave_2","/user/slave_3","/user/slave_4","/user/slave_5"]
        }
      }
    }
  }
}
  

А затем вызовите его в ConfigFactory

     val system = ActorSystem("routersDemo", ConfigFactory.load().getConfig("routersDemo"))