| /** |
| * |
| * Licensed to the Apache Software Foundation (ASF) under one or more |
| * contributor license agreements. See the NOTICE file distributed with |
| * this work for additional information regarding copyright ownership. |
| * The ASF licenses this file to You under the Apache License, Version 2.0 |
| * (the "License"); you may not use this file except in compliance with |
| * the License. You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, software |
| * distributed under the License is distributed on an "AS IS" BASIS, |
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| * See the License for the specific language governing permissions and |
| * limitations under the License. |
| */ |
| #include "TestBase.h" |
| #include "Catch.h" |
| #include "PublishKafka.h" |
| #include "SingleProcessorTestController.h" |
| |
| namespace org::apache::nifi::minifi::test { |
| |
| TEST_CASE("Scheduling should fail when batch size is larger than the max queue message count", "[testPublishKafka]") { |
| LogTestController::getInstance().setTrace<TestPlan>(); |
| LogTestController::getInstance().setTrace<processors::PublishKafka>(); |
| const auto publish_kafka = std::make_shared<processors::PublishKafka>("PublishKafka"); |
| SingleProcessorTestController test_controller(publish_kafka); |
| publish_kafka->setProperty(processors::PublishKafka::ClientName, "test_client"); |
| publish_kafka->setProperty(processors::PublishKafka::SeedBrokers, "test_seedbroker"); |
| publish_kafka->setProperty(processors::PublishKafka::QueueBufferMaxMessage, "1000"); |
| publish_kafka->setProperty(processors::PublishKafka::BatchSize, "1500"); |
| REQUIRE_THROWS_WITH(test_controller.trigger(""), "Process Schedule Operation: Invalid configuration: Batch Size cannot be larger than Queue Max Message"); |
| } |
| |
| } // namespace org::apache::nifi::minifi::test |
