草庐IT

apache-kafka-streams

全部标签

java - 调试自定义 Kafka 连接器的简单有效方法是什么?

我正在使用几个Kafka连接器,我在控制台输出中没有看到它们的创建/部署有任何错误,但是我没有得到我正在寻找的结果(没有任何结果),期望或其他)。我根据Kafka的示例FileStream连接器制作了这些连接器,因此我的调试技术基于示例中使用的SLF4J记录器的使用。我搜索了我认为会在控制台输出中生成的日志消息,但无济于事。我是不是在错误的地方寻找这些消息?或者是否有更好的方法来调试这些连接器?我在实现中引用的SLF4J记录器的示例用法:KafkaFileStreamSinkTaskKafkaFileStreamSourceTask 最佳答案

java - 如何使用 Java stream api 过滤 map ?

Mapmap=newHashMap();map.put(1,"f");map.put(2,"I");map.put(3,"a");map.put(4,"c");....etc现在我有一个列表:Listpicks={1,3}我想取回一个字符串列表,即在“选择”列表中找到的与键值匹配的映射值。所以,我希望取回{"f","a"}作为结果。有没有办法使用javastreamapi以优雅的方式做到这一点?当只有一个值时,我是这样做的:map.entrySet().stream().filter(entry->"a".equals(entry.getValue())).map(entry->ent

java - Apache Commons Pool 2 中的 maxTotal 和 maxIdle 有什么区别?

我正在使用ApacheCommonsPool2实现来为我的应用程序提供对象池机制。到目前为止,我已经在我的代码中将maxTotal()和maxIdle()的默认值设置为10。但是我不明白它们之间有什么区别?如果我将maxIdle()设置为非常小(比如0)或非常大(等于maxTotal())的值会怎样?注意:Apache类在内部建议对上述两个配置使用默认值8。 最佳答案 连接池是一种与无限数量的并发用户共享有限数量的数据库连接的技术。最大总连接数(maxTotal)包括Activity连接数和空闲连接数,即正在使用的连接数和当前未使用

java - 使用 Stream 比较两个集合 - anyMatch

我想比较list2中的任何对象是否存在于list1中。我可以遍历两个列表并使用.contains()比较所有元素,但我想知道是否有更有效的方法。我找到了this我正在尝试实现建议的方法:Listlist1;Listlist2;booleananyMatch=list1.stream().anyMatch(x->x.equals(list2.stream()));System.out.println(anyMatch);当我这样做时,我经常得到false,即使我期望的是true。怎么会? 最佳答案 根据您的评论,您有两个列表,list

Java Apache FTPClient : How to know my current directory

我的问题很简单:我在连接到FTP的简单应用程序中使用Apachecommons.netAPI,我可以使用changeWorkingDirectory方法更改工作目录。但是...我怎么知道我的当前目录而不更改它? 最佳答案 printWorkingDirectory()返回当前工作目录的路径名。Here'sthereference. 关于JavaApacheFTPClient:Howtoknowmycurrentdirectory,我们在StackOverflow上找到一个类似的问题:

java - 如何使用 Apache Commons 解压 TAR 文件

我正在使用ApacheCommons1.4.1库压缩和解压缩".tar.gz"文件。我在最后一点遇到了麻烦——将TarArchiveInputStream转换为FileOutputStream。奇怪的是,它在这条线上中断了:FileOutputStreamfout=newFileOutputStream(destPath);destPath是一个具有规范路径的文件:C:\DocumentsandSettings\Administrator\MyDocuments\JavaWorkspace\BackupUtility\untarred\Test\subdir\testinsub.txt

java - Maven 无法执行目标 org.apache.maven.plugins :maven-clean-plugin:2. 5:clean 无法删除 access_log

我正在尝试使用maven和tomcat运行简单的struts项目。当我尝试执行下一个目标时:cleaninstalltomcat7:run我得到了MojoExecutionException:[ERROR]Failedtoexecutegoalorg.apache.maven.plugins:maven-clean-plugin:2.5:clean(default-clean)onprojectmyproject:Failedtocleanproject:FailedtodeleteD:\EclipseWorkspace\myproject\target\tomcat\logs\acc

java.lang.NoClassDefFoundError : org/apache/http/conn/scheme/SchemeSocketFactory 错误

我正尝试通过AWSCredentials发送邮件但出现异常java.lang.NoClassDefFoundError:org/apache/http/conn/scheme/SchemeSocketFactory我添加了这些jar:aws-java-sdk-1.3.11.jaraws-java-sdk-1.3.11-javadoc.jaraws-java-sdk-1.3.11-sources.jaraws-java-sdk-flow-build-tools-1.3.11.jarcommons-logging.jarhttpclient-4.0-alpha4.jarhttpcore-4

java - 速度与 Apache Tiles

什么更好?我们要开始一个新的网络项目,这是一个选择哪种技术的问题。项目包括SpringMVC+WebFlow。在支持、扩展、性能方面有什么好的/坏的经验吗?谢谢。 最佳答案 Velocity和Tiles是两种不同的野兽—Tiles是布局引擎,而Velocity是模板引擎。它们在功能方面没有任何交集。根据您的问题,我可以猜测您可能不会使用JSP。这是一个聪明的举动。Velocity是现有的模板引擎之一,它的工作绝对出色。如果您选择遵循View的模板引擎路线,请查看commentit.这是我创建的一个小型、简单且快速的布局引擎。它可能会

java - 什么是 Apache 速度?

关闭。这个问题需要更多focused.它目前不接受答案。想改进这个问题吗?更新问题,使其只关注一个问题editingthispost.关闭8年前。Improvethisquestion谁能解释一下,ApacheVelocity是什么?它的目的是什么?最好能提供一个示例。提前致谢。