草庐IT

apache-kafka-streams

全部标签

java - 使用 Apache Lucene 删除磁盘中的所有索引数据/文件?

如何使用ApacheLucene刷新/删除/删除磁盘中的所有索引文件/数据。到目前为止这是我的代码,但我仍然无法删除索引文件。请帮帮我...测试:publicclassTest{privatestaticfinalStringINDEX_DIR="/home/amila/Lucene/REST/indexing";publicstaticvoidmain(String[]args){try{ContentIndexercontentIndexer=newContentIndexer(INDEX_DIR);contentIndexer.flushDisk();System.out.pri

java - 从java以编程方式将apacheds数据导出和导入到LDIF

我已经在ApacheDirectoryStudio中创建了一个服务器。我还创建了一个分区,并从Java向该服务器插入了一些条目。现在我想以编程方式备份​​和恢复LDIF文件中的这些数据。我是LDAP的新手。因此,请向我展示使用java以编程方式将条目从我的服务器导出和导入到LDIF的详细方法。当前解决方案:现在我正在使用这种方法进行备份:EntryCursorcursor=connection.search(newDn("o=partition"),"(ObjectClass=*)",SearchScope.SUBTREE,"*","+");Charsetcharset=Charset

java - Apache poi 分页符

我需要创建一个简单的word文档以便从java程序进行打印。有必要将输出打印在单独的页面上。我正在使用以下代码:XWPFDocumentdocument=newXWPFDocument();XWPFParagraphparagraph=document.createParagraph();XWPFRunrun=paragraph.createRun();run.setText("TITLE");run.addCarriageReturn();run.setText("sometextandstuffhere");run.addBreak(BreakType.PAGE);run.setT

java - 如何运行以下命令来测试kafka服务器是否安装正确?

我已经安装了Kafka和zookeeper。动物园管理员工作正常。但是,当我尝试运行Kafka服务器时,出现以下错误。请帮我解决这个问题。先感谢您!!!从C:\kafka-0.9.0.1运行的命令:.\bin\windows\kafka-server-start.bat.\config\server.properties错误信息:类路径为空。请先构建项目,例如通过运行“gradlewjarAll” 最佳答案 当你安装Kafka时,你是从源码下载还是二进制下载?下载源代码分发时会出现此问题。要解决此问题,请通过二进制下载链接下载:Ka

java - Streaming 的多项操作能否打破 Demeter 法则?

我有点想用Java8流编写Selenium页面对象,如下面的代码所述,并收到评论说我的代码违反了Demeter法则,因为我在一行中执行了很多操作。我被建议将代码分解为第一个流以收集列表并运行另一个流操作来进行匹配(简而言之,根据需要将其分解为多个流)。我不相信,因为引入Stream是为了处理数据处理,如果我们将它分解成多个流,那么使用流就没有意义了。之前我曾在一个网络安全项目中工作,其中数百万条记录通过流式处理和多个逻辑操作对数据进行排序。请分享您的想法,我已按照审阅者的建议对其进行了更改,但他无法解释原因,我想了解有关流的更多信息以及利用Java8的这一强大新增功能的正确方法。示例代

java - 如何选择一个Kafka transaction.id

我想知道我能否在理解Kafka中的交易方面获得帮助,尤其是如何使用transaction.id。这里是上下文:我的Kafka应用程序遵循以下模式:使用来自输入主题的消息,进行处理,然后发布到输出主题。我不使用KafkaStreamsAPI。我在一个消费者组中有多个消费者,每个消费者都在自己的轮询线程中。有一个带有工作线程的线程池,该线程用于执行消息处理并将其发布到输出主题。目前,每个线程都有自己的生产者实例。我正在使用已发布的事务API,以确保消耗偏移量的更新和对输出主题的发布原子地进行到目前为止,我的假设包括:如果我的进程在中间事务中崩溃,那么该事务中的任何内容都不会发布,也不会消耗

java - Spliterator 与 Stream.Builder

我读了一些关于如何创建有限的Stream的问题(FinitegeneratedStreaminJava-howtocreateone?,Howdostreamsstop?).建议实现Spliterator的答案。Spliterator将实现如何提供以及下一个提供哪个元素的逻辑(tryAdvance)。但是还有另外两个非默认方法trySplit和estimateSize()我必须实现。Spliterator的JavaDoc说:Anobjectfortraversingandpartitioningelementsofasource.Thesourceofelementscoveredby

java - apache-tomcat 6.0.20 中的共享 jar

我是JWS的新手。我有一个web应用程序(几个web服务),我想在linux系统上使用tomcat6.0.20进行部署。如果我生成一个包含所有使用的库的.war文件并将其放在webapps目录中,一切都很好,但我想共享这些jar,而.war文件本身太大了。首先,我尝试了直观的方式-我创建了一个指向包含jars的目录的链接(WEB-INF/lib),但奇怪的是它无法部署(如果目录不是链接,它就会启动):SEVERE:Errorconfiguringapplicationlistenerofclasscom.sun.xml.ws.transport.http.servlet.WSServl

java - org.apache.commons.net.ftp.FTPClient listFiles() 问题

org.apache.commons.net.ftp.FTPClient的listFiles()方法在127.0.0.1上的Filezilla服务器上工作正常,但返回null在公共(public)FTP服务器的根目录,例如belnet.be。下面的链接中有一个相同的问题,但enterRemotePassiveMode()似乎没有帮助。ApacheCommonsFTPClient.listFiles会不会是列表解析的问题?如果是这样,如何解决这个问题?编辑:这是一个目录缓存转储:FileZilla目录缓存转储正在转储1个缓存目录Entry1:Path:/Server:anonymous@

java - 如何使用 apache velocity 从列表中删除重复元素

我有一个包含重复元素的列表,我需要使用速度例如,帖子包含重复元素#foreach($pin$posts)$p.name//willbeunique#end我想使用velocity删除重复项,任何帮助将不胜感激 最佳答案 这是可能的,这应该取决于您的速度版本。比上面的答案更简洁。#set($uniquePosts=[])#foreach($postin$posts)#if(!$uniquePosts.contains($post.name))#if($uniquePosts.add($post.name))#end##notethei