草庐IT

apache-kafka-streams

全部标签

java - 如何将 JCIFS 与 apache VFS 结合使用来访问 SMB URL?

我正在尝试使用smbURL访问本地计算机上的文件夹。我的项目正在使用jar:commons-vfs2-2.0.jar和jcifs-1.3.17.jar(以及所有其他所需的jar)。完整的代码是:publicstaticvoidmain(String[]args)throwsFileSystemException{jcifs.Config.registerSmbURLHandler();StaticUserAuthenticatorauth=newStaticUserAuthenticator(,,);FileSystemOptionsopts=newFileSystemOptions(

java - Apache Camel onException

我想捕获路由中的所有异常。我添加这个OnExeption:onException(Exception.class).process(newMyFunctionFailureHandler()).stop();然后,我创建了MyFunctionFailureHandler类。publicclassMyFunctionFailureHandlerimplementsProcessor{@Overridepublicvoidprocess(Exchangeexchange)throwsException{Throwablecaused;caused=exchange.getProperty(

java - 在 intelliJ 中找不到 Apache Tomcat 7 HTTP 连接器节点

我正在使用GWT、ApacheTomcat7上的Maven和intelliJidea开发应用程序。我最近调试并运行了我的应用程序,但遇到了以下问题:运行Tomcat7时出错:找不到HTTP连接器节点:在server.xml中设置一个节点。ApacheTomcat运行代码:"c:\programfiles(x86)\jetbrains\intellijidea11.1.4\jre\jre\bin\java"-Dclassworlds.conf=C:\Tools\apache-maven-3.1.1\bin\m2.conf-Dmaven.home=C:\Tools\apache-maven

java - REST 服务未在 Apache wink 中注册到 Spring 和 Maven

我有一个Maven项目,其依赖项如下:wink.version=1.1.3-incubating和spring.version=3.0.5.RELEASESpring中的应用上下文包括:web.xml包括:contextConfigLocationclasspath:META-INF/wink/wink-core-context.xmlclasspath:applicationContext.xmlorg.springframework.web.context.ContextLoaderListenerrestServletorg.apache.wink.server.internal

java - 在 Apache Kafka 中存储图像?

Kafka的大用户(例如LinkedIn)是否将上传的图像存储在Kafka中?我喜欢将所有内容放入日志的架构简单性,但我担心它在实践中可能行不通。 最佳答案 理论上没有限制,因为您可以轻松地将图像以二进制形式存储在Kafka队列中。但是可能还有其他问题..我会尝试对此进行一些思考消费者配置中有一个message.max.bytes参数,默认值为1000000。这样做实际上是为了防止代理耗尽内存,因为消费者没有流式传输消息的选项,必须分配内存才能读取消息。一种解决方法是压缩Kafka中的消息以节省空间。我能找到的最合适的条件是通过发送

java - Apache Tiles 3 和 Tomcat 8

当我使用Tomcat8时出现以下错误:Causedby:java.io.IOException:ServletExceptionincludingpath'/WEB-INF/jsp/tiles-base.jsp'.atorg.apache.tiles.request.servlet.ServletUtil.wrapServletException(ServletUtil.java:61)atorg.apache.tiles.request.servlet.ServletRequest.doInclude(ServletRequest.java:245)atorg.apache.tile

java - Apache 点燃查询

我已经使用自动持久性创建了一个缓存,连接到Mysql数据库。100万行在启动时填充到该节点中。节点处于分区模式当我尝试使用SQL查询从缓存中检索数据时,它总是返回空数组。我已经使用“CacheTypeMetadata”为缓存编制了索引。请任何人指出我遗漏或做错了什么。我一直在关注教程,但我无法弄清楚为什么我的查询无法正常工作。提前致谢!缓存:CacheConfigurationcfg=CacheConfigMd5.cache("DataMd5Cache",newJDBCFactory());DataLoaderMd5Key:publicclassDataloadermd5Keyimpl

java - 使用 Java 8 Stream 读取文本文件 block

Java8有一种方法可以从文件的行创建流。在这种情况下,foreach将逐行执行。我有一个具有以下格式的文本文件..bunchoflineswithtext$$$$bunchoflineswithtext$$$$我需要将$$$$之前的每组行放入Stream中的单个元素中。换句话说,我需要一个字符串流。每个字符串都包含$$$$之前的内容。执行此操作的最佳方法(开销最小)是什么? 最佳答案 我想不出一个延迟处理线条的解决方案。我不确定这是否可行。我的解决方案生成一个ArrayList。如果您必须使用Stream,只需对其调用stream

java - Apache Kafka 是否提供异步订阅回调 API?

我的项目将ApacheKafka视为老化的基于JMS的消息传递方法的潜在替代品。为了让这个过渡尽可能的顺利,如果替换队列系统(Kafka)有一个异步订阅机制就更理想了,类似于我们当前项目的JMS机制使用MessageListener。和MessageConsumer订阅主题并接收异步通知。我不太关心Kafka是否严格遵守JMSAPI,但相反,如果不需要,我宁愿不重新设计我们的整个发布-订阅-通知类套件。我可以找到各种KafkaConsumerpollingexamples,但到目前为止还没有找到任何通过异步通知向客户端通知新消息的示例。有谁知道当前版本的Kafka(截至本文发布时为0.

java - 了解Kafka写入速度

鉴于此1.五机Kafka集群2.1个主题,1个分区3.消息持久化存储4.每条消息1KB5.10个生产者现在,这个集群的最大写入能力是否等于一个Java线程写入磁盘的最大写入能力?如果不是,那会是什么? 最佳答案 如果您只有一个分区,那么kafka无法扩展您的主题并且只能使用5个实例集群中的一台机器。无法判断您的java代码编写得如何,但结果将与我假设的kafka类似,但存在细微差异,因为kafka针对磁盘写入进行了优化。 关于java-了解Kafka写入速度,我们在StackOverfl