测试Flink-Kafka集成

文章/答案/技术大牛

发布

1回答

apache-flink、flink-streaming

如何设置一个单元测试环境，在这个环境中我可以创建Kafka主题，使用FlinkKafkaProducer对它们进行写入，并使用FlinkKafkaConsumer对它们进行读取？

浏览 5提问于2020-08-03得票数 0

回答已采纳

1回答

是否可以根据特定的参数对事件进行分组，并在每个组中运行Flink CEP模式？

apache-flink

我的flink-kafka消费者正在访问这些事件。现在，在flink中，我可以根据主机名对这些事件进行分组吗?在每个组中，我可以检查模式吗？

浏览 0提问于2018-12-07得票数 0

回答已采纳

2回答

FlinkKafkaException:未能将数据发送给Kafka:自批处理创建以来，“`topic`”：120001 ms的过期19条记录已过

apache-kafka、apache-flink

我正在使用Flink 1.13.1，并试图用10k记录的RPS(每秒速率)将数据写入kafka。我有一个由30个经纪人组成的kafka集群，我的flink工作做了一个过滤器操作员，只将数据汇到kafka。下面是我的生产者设置，最初我有5个接收器主题分区，但现在10个，我仍然得到同样的问题。另外，我尝试将request.timeout.ms设置为1分钟，而不是卡夫卡默认的30秒，但仍然得到了120001 ms has passed since batch creation。由于此错误，检查点失败。检查点大小仅为107 is，因为flink只向kafka提交偏移。作业并行性为36。这是纳卡的属性和

浏览 23提问于2022-04-11得票数 1

1回答

apache kafka中的生产者端压缩

apache-kafka、apache-flink

编辑-使用flink-kafka连接器

浏览 0提问于2018-08-10得票数 1

1回答

Flink是否知道在运行时添加了Kafka分区

apache-flink

我有一个关于Flink-Kafka的问题来源： flink应用程序从检查点恢复后启动，并且运行良好。

浏览 23提问于2019-10-07得票数 1

1回答

是否可以使用输入流中的时间戳在Flink中创建翻滚窗口。如果是，那么是如何实现的？

apache-kafka、apache-flink、flink-streaming

我一直在尝试在Flink-Kafka消费者上使用翻滚窗口。

浏览 17提问于2020-01-02得票数 0

1回答

生成“假”流数据。卡夫卡

java、apache-kafka、apache-flink、stream-processing、event-stream-processing

我试图生成流数据，以模拟在不同的时间范围内接收两个值( Integer类型)的情况，使用时间戳和Kafka作为连接器。我应该直接从卡夫卡得到数据吗？如果是的话，最好的方法是什么？或者，如果我把Flink制作出来的数据作为一个制作人，发送给Kafka，然后用Flink在结束时再使用它，也许会更好？我怎么才能从弗林克那里做到呢？或者，还有另一种简单的方法来生成流数据并将其传递给Kafka。

浏览 2提问于2018-08-20得票数 2

2回答

集成测试

.net、nunit、integration-testing

我对不同的类和每个不同的模块进行了测试。我应该如何一起测试所有这些交响乐？

浏览 1提问于2011-06-05得票数 4

3回答

集成测试/单元测试:做太多的集成测试？

unit-testing、mocking、tdd、integration-testing

我一直在设计一些单元测试来模拟每个单元所具有的每个依赖项。这与预期的一样。我现在需要做集成测试。例如，我有一个依赖于另外两个层的层，我已经将每个单独的层作为一个单元进行了单独测试，以模拟每个依赖项，但现在我需要执行集成测试。那么，我应该为Layer2做一个集成测试吗？其中包括以下工作流再说一次，这里没有任何东西被嘲笑，它们是集成测试。我看到的问题是，我的Layer1

浏览 1提问于2013-07-04得票数 3

1回答

mvn集成-测试不执行黄瓜集成测试

java、spring-boot、selenium、maven、cucumber

问题 </executions>

浏览 3提问于2022-06-10得票数 0

1回答

什么是集成测试以及如何执行集成测试？

php、testing

所有SDLC模型都将集成测试作为其中一个层。在我看来，集成测试实际上是测试的“级别”，而不是测试的“类型”。我说的对吗？

浏览 0提问于2016-09-22得票数 0

3回答

与“集成测试”、“系统测试”和“系统集成测试”混淆

manual-testing、terminology

我的理解如下：系统测试.单个系统作为一个整体的测试系统集成测试-测试系统(例如，前端与数据库和外部提供者)。在实践中，通常没有对各个子系统的系统测试(我们通常不会单独测试UI或数据库层)，我们在SIT中一起测试它。我甚至可以认为UI或DB层是一个独立的系统吗？但是，当测试整个过程时，不是再次进行系统测试吗？

浏览 0提问于2021-02-27得票数 1

回答已采纳

1回答

如何运行非spock tests>？

grails、spock

在我的grails测试中，我有一系列集成测试，它们是标准的grail集成测试和sock测试。我可以通过以下方式运行所有集成我只能通过以下方式运行spock集成测试如何运行所有不是spock测试的集成测试？

浏览 4提问于2013-08-25得票数 1

回答已采纳

3回答

集成测试是一个总括术语吗?如果是的话，它包括哪些类型的测试？

unit-testing、testing、integration-testing、categorization

我觉得“集成测试”的概念令人困惑。测试系统配置功能/特性-独立(数据库集成工作，依赖关系被正确注入，安全基类工作) 单元集成测试(在不调用外部库的情况下测试</e

浏览 5提问于2010-07-14得票数 7

2回答

Maven在集成测试阶段运行码头

java、maven、jetty、integration-testing、maven-failsafe-plugin

因此，当我输入mvn failsafe:integration-test时，它会显示我的集成测试(这很棒)。

浏览 10提问于2014-08-04得票数 5

回答已采纳

2回答

大爆炸集成测试与系统测试

testing、sdlc、integration-testing

在“大爆炸”集成测试中，我们将单元测试后的所有模块合并为一个整体，以查看是否存在错误。如果是这样的话，那么Bang集成测试和系统测试不是基本相同的:它们都测试整个系统吗？如果它们是相同的，那么为什么大爆炸集成测

浏览 0提问于2019-06-20得票数 1

回答已采纳

1回答

强制执行Maven阶段

java、maven

我有一个带有pre-integration-test和post-integration-test阶段的Maven POM，如下所示。 <id>start-server</id> <goals> </goals> </configu

浏览 1提问于2015-06-10得票数 3

回答已采纳

2回答

集成测试与连续集成测试的区别

continuous-integration、integration-testing

在我的大学里，我学习了集成测试，在集成测试中，我们将整个代码组合在一起，然后在完成单元测试之后立即测试它。我很困惑，所以我从维基百科上读到了这件事，但没什么用。我读了下面的两个链接连续积分 ELI5

浏览 0提问于2017-07-15得票数 5

回答已采纳

3回答

在单元测试框架中的鞋角集成和系统测试

.net、unit-testing、integration-testing

如所示，我感兴趣的是创建一个创建服务器和许多客户端的集成测试工具，其中所有都运行在单个进程中。但是，一旦我实现了这个目标，我将非常想在一个单元测试框架(NUnit或VS团队测试)中执行这样的集成&系统测试。优点集成测试可能是通过每次构建实

浏览 0提问于2010-06-19得票数 3

回答已采纳

1回答

集成测试使用模拟吗？

unit-testing、testing、integration-tests、mocking

我目前在一个软件测试类，在我们的学期项目，我们必须对它执行多种类型的测试，如单元测试和集成测试。对于集成测试，教授说在我们的集成测试中使用模拟和模拟库(如EasyMock和Mockito)。集成测试是对外部类、模块、服务等的测试。如果您要测试多个类和服务，为什么要在集成测试中适当地使用模拟和存根呢？

浏览 0提问于2017-04-18得票数 37

回答已采纳

点击加载更多