草庐IT

Kafka-Source

全部标签

java - Sonar Java : check the quality of the test classes source code?

是否可以在Sonar中检查*Test.java源代码的质量,例如方法最大尺寸100行?问题是,JavaJunit测试随着生产代码的增加而增加,复杂性也在增加。我们有超过1000行和2个方法的单元测试类。我们想在Sonar中检查这些*Test.java类的一些规则。 最佳答案 从Sonar3.1开始,它包含一个插件,该插件具有针对单元测试执行的特定PMD规则(aJIRAwascreatedforthat)。您可以在Configuration>QualityProfiles>CodingRules中看到它们。但是,您似乎想要对测试源代码

java - eclipse `allow output folders for source folders`

在EclipseIDE中创建新的Java(不是JavaEE)项目时,我看到一个选项,上面写着Allowoutputfoldersforsourcefolders。那是干什么用的? 最佳答案 它允许为每个源文件夹定义一个单独的输出文件夹(即eclipse创建编译的.class文件的文件夹),而不是将所有源文件夹的所有.class文件存储在同一个输出文件夹中。 关于java-eclipse`allowoutputfoldersforsourcefolders`,我们在StackOverflo

java - GWT webappcreator 创建 Maven 项目 : the source attachment does not contain the source for the file URLClassPath. 类

我创建了一个基于Maven2的GWT应用程序,将其导入到Eclipse中,当我作为GWTWeb应用程序进行调试时,Eclipse调试session因FileNotFoundException而暂停。它显示一个窗口说:源附件不包含文件URLClassPath.class的源。我完全清除了Eclipse工作区(和.metadata子目录),创建/导入了一个空白项目,同样的事情发生了。如果我执行RunAsGWTWeb应用程序,它工作正常(有几个警告)。我需要调整什么才能让它在Debug模式下工作?重现问题的步骤1)创建应用webAppCreator-noant-maven-XnoEclips

搭建kafka测试环境

搭建kafka测试环境启动zookeeperdockerpullbitnami/zookeeperdockerrun-d--namezookeeper\-eALLOW_ANONYMOUS_LOGIN=yes\bitnami/zookeeper:latest启动kafka创建网络与连接dockernetworkcreatekafka-networkdockernetworkconnectkafka-networkzookeeperdockernetworkconnectkafka-networkkafka安装kafkadockerpullbitnami/kafka启动kafkadockerrun

kafka:java集成 kafka(springboot集成、客户端集成)

摘要对于java的kafka集成,一般选用springboot集成kafka,但可能由于对接方kafka老旧、kafka不安全等问题导致kafak版本与spring版本不兼容,这个时候就得自己根据kafka客户端api集成了。一、springboot集成kafka具体官方文档地址:https://docs.spring.io/spring-boot/docs/current/reference/htmlsingle/1、加入依赖,spring-boot-starter-web和spring-kafka的版本号可以看它们依赖的spring版本是否一致,这里pom依赖如下:org.springfr

java - Kafka 领导人选举导致 Kafka Streams 崩溃

我有一个KafkaStreams应用程序在Kafka集群中消费和生产,该集群具有3个代理,复制因子为3。除了消费者偏移主题(50个分区)之外,所有其他主题每个都只有一个分区。当代理尝试首选副本选举时,Streams应用程序(运行在与代理完全不同的实例上)失败并出现错误:Causedby:org.apache.kafka.streams.errors.StreamsException:task[0_0]exceptioncaughtwhenproducingatorg.apache.kafka.streams.processor.internals.RecordCollectorImpl

java - Kafka - 生产者确认

我在一个视频教程中看到,KafkaBroker在生产者发布消息时支持3种类型的确认。0-发射后不管1-领导确认2-所有经纪人的确认我正在使用Kafka的JavaAPI来发布消息。这是必须使用特定于每个经纪人的server.properties为每个经纪人设置的东西,还是必须由生产者设置的东西?如果必须由生产者设置,请说明如何使用JavaAPI设置。importorg.apache.kafka.clients.producer.KafkaProducer;importorg.apache.kafka.clients.producer.ProducerRecord;importorg.ap

Kafka学习笔记

常见的消息队列对比详细对比见:https://note.dolyw.com/mq/00-MQ-Select.html#_6-%E5%AF%B9%E6%AF%94仅截图部分优缺点对比。KafkaVSRedis参考自:https://juejin.cn/post/6960652072588935182所谓用Redis实现消息队列,即:使用list结构。lpush左边插入数据,rpop右边取出数据即可。使用Kafka而不使用Redis的几点原因:消息持久化:redis是内存数据库,虽然有aof和rdb两种机制进行持久化,但这只是辅助手段,这两种手段都是不可靠的。当redis服务器宕机时一定会丢失一部

java - eclipse 调试 : Source not found for

我知道这是一个常见问题,但从昨天开始我就一直在网上搜索我的问题的解决方案,但一直找不到!我将EclipseHelios与Tomcat6.0.2一起使用,每当我尝试使用tomcat和eclipse调试我的代码时,我都会收到错误Sourcenotfound,即使是我自己编写的代码,而不仅仅是所有的jar文件我正确设置了java构建路径,我也在使用jdk1.6.0并且也正确设置了这个,所以这不是问题,如果我右键单击它,它会在我调试时显示代码调试控制台并转到EditSourceLookup...。因为这将只显示调试器运行的源代码,所以我进入Run->DebugConfigurations并在J

java - Kafka 0.9 - 如何通过 java api 创建主题

关闭。这个问题需要更多focused.它目前不接受答案。想改进这个问题吗?更新问题,使其只关注一个问题editingthispost.关闭7年前。ImprovethisquestionKafka新手。很难弄清楚如何使用java-api在0.9版本中创建主题。这answer处理0.8。我看到Cluster有查询分区信息、主题等的方法。但我看不到如何动态创建主题。