我尝试使用Kafka Streams使用不同大小的时间窗口来聚合大量数据。
我将缓存大小增加到2 GB，但当我在1小时内设置窗口大小时，CPU负载达到100%，应用程序开始变慢。
我的代码如下所示：
val tradeStream = builder.stream<String, Trade>(configuration.topicNamePattern, Consumed.with(Serdes.String(), JsonSerde(Trade::class.java)))
tradeStream
.groupBy(
{ _, trade -&
浏览 2提问于2017-12-08得票数 0
在中，有什么方法可以控制System.in和System.out的文件编码吗？
Sun/Oracle使用：
java.io.BufferedInputStream - Stdin java.io.PrintStream - Stdout
IBM使用：
com.ibm.jvm.io.ConsoleInputStream - Stdin com.ibm.jvm.io.ConsolePrintStream - Stdout
这个问题出现在IBM中，其中输出十六进制中的数据字节数组:308209d6092.(就在写信给System.out之前)
但是在同一个文件中读取并以十六进制形式写出的结果是:
浏览 4提问于2017-02-13得票数 0
im面临着java.lang.OutOfMemoryError的问题:在Cloud中运行应用程序时直接缓冲内存。
在这里，我试图从Oracle 中获取数据，该数据库有25K条记录，从带有1vCore的入站表中获取。
该错误发生在所有流完成之后，最后它将打印错误日志，如下所示。
2020-03-29 11:17:30.640错误std-err ForkJoinPool.CommonPool-0:线程"ForkJoinPool.commonPool-worker-0“java.lang.OutOfMemoryError中的异常:直接缓冲内存2020-03-29 11:17:30.640错
浏览 1提问于2020-03-29得票数 0
我正在向grpc服务发送数据，并收到错误消息：
遇到流结束中帧
这是什么意思。连接被中断了，或者没有发送足够的数据。是我的客户端未能发送足够的消息数据，还是在处理过程中出现了连接中断。我从这里没有足够的信息。
如果您不知道这里出了什么问题，请告诉我这是否意味着连接在处理过程中过早关闭，或者数据传输没有预期的那么长，但没有连接问题。
我正在使用特使代理(Lyft)提供的此过滤器：
我正在使用来自特使的这座桥：
它要求前面是0字节，长度是4个字节的大印度。
对我来说，这是一条冗长、丑陋、毫无意义的信息：
Jul 23, 2019 2:26:06 PM io.grpc.netty.shaded.i
浏览 31提问于2019-07-23得票数 0
1回答
我使用mysql作为我的数据库。我在我的java代码中得到了字节数组。然后，我将这个字节数组作为LONGBLOB存储在数据库中。现在，在从db中检索它时，我使用了以下代码：
package com.sendSms;
import java.awt.image.BufferedImage;
import java.io.*;
import java.sql.*;
import javax.imageio.ImageIO;
import org.apache.commons.io.IOUtils;
public class SampleTest {
public Connection ge
浏览 1提问于2017-01-18得票数 1
1回答
捕获流
、、、
我使用Java，需要将音频/视频流保存到本地文件中。
到目前为止，我成功地发送了RTSP命令并保存了流。
但是，每个RTP包(DynamicRTP-Type-96)都包含一个头和一个有效负载。有效载荷持有NAL头和实际NAL。
应该从这个入站流中实际保存到最终的视频文件中吗？
您是否知道Java lib可以对每个数据包进行解析？
浏览 4提问于2012-08-08得票数 1
我已经设置了阈值，以便在基础设施的数据狗中获取警报。警报即将出现在data dog UI上，但如何使用JAVA或python通过API调用获取所有警报数据。我只需要警报数据。
浏览 8提问于2017-08-01得票数 1
回答已采纳
1回答
我正在将Mule应用程序从3.9.0迁移到Mule 4.4.0。我使用Java对象跨传输传播元数据和其他对象。下面是这个类的一个片段：
package com.test;
import java.io.Serializable;
import java.util.HashMap;
import java.util.Map;
public class DataWrapper implements Serializable {
private static final long serialVersionUID = 1L;
private final Map<
浏览 6提问于2022-08-16得票数 0
回答已采纳
2回答
我想从TCP流中读取一个字符串，该流的字节长度后面跟着实际的数据。在Python里，我会
length = ord(stream.read(1))
data = stream.read(length)
如何在Java中实现相同的操作？我有一个缓冲器(容量为257)。
stream.read(buffer); // cannot specify a size here
int length = buffer.get();
byte[] data = new byte[length];
buffer.get(data);
不幸的是，这不起作用: get()调用读取缓冲区中的数据:-(
我可能需要一
浏览 2提问于2009-08-22得票数 3
回答已采纳
4回答
FilterOutputStream在Java中的实际用法是什么？来自javadocs：
该类是筛选输出流的所有类的超类。这些流位于一个已经存在的输出流(底层输出流)之上，它使用该流作为其基本的数据接收器，但可能在此过程中转换数据或提供其他功能。
对我来说，它似乎有与OutputStream相同的方法(可能是因为某种原因而重写它们？)。它提供了什么样的数据“转换”，以及何时可以在自己的Java应用程序中使用它？
浏览 2提问于2013-07-10得票数 5
回答已采纳
我似乎找不到让readObject()将其内容传递给对象变量的方法。当我跨过Load函数时，我到了"temp = (HashMap) ois.readObject()；“在执行这一行之前，我能够在Eclipse表达式窗口中看到用oos编写的HashMap's数据，这样我就知道数据在那里了，但是，当这一行执行时，我就会跳到IOException捕捉和EOF。根据我所读到的，这是预期的，但我没有找到捕获EOF的方法(可用循环()和readObjectInt()没有工作)。我在Android仿真器上运行这个。如有任何建议，将不胜感激。
public void Save(Pottylo
浏览 3提问于2013-04-13得票数 0
我提供了代码片段，这些代码应该正常工作，但它不能工作。
总之，我的流程是由石英触发的，从数据库读取一些数据，循环到结果，在每个循环上做一些事情，然后完成。
当服务(http出站)返回没有什么可返回的结果时，一切正常，但是当选择(在flow中)不是默认时，它将重定向到子流，xslt在其中执行和保存文件。文件保存就像它应该保存的那样(如果xml适合标准，我用外部工具检查过)，并打印出第3号作为它已经完成的证据(抛出错误前的几行)，但是在那之后我得到了下面的错误。有人知道为什么吗？我没有主意了。
我的流量：
<flow name="msp2bassGettingContent"
浏览 1提问于2014-01-22得票数 0
回答已采纳
1回答
读取Java 8的流并行性API：
当使用这个流API的并行性时，还不清楚如何调优要使用的线程数？
计划在非常特定的计算机类型和一致的数据类型上运行这个程序，所以我想我可以在一组不同的设置上对它进行基准测试，然后使用最好的线程数。
浏览 1提问于2015-06-16得票数 4
当我在一个流中使用两个HTTP端点时，Mule抛出了这个异常。我已经找到了解决这个问题的方法:以异步模式使用第二个HTTP端点，但这不是一个好方法。
ERROR DefaultSystemExceptionStrategy [[testdemo].connector.http.mule.default.receiver.03]: Caught exception in Exception Strategy: Attempted read on closed stream.
java.io.IOException: Attempted read on closed stream.
at
浏览 1提问于2013-04-04得票数 0
回答已采纳
在之前的Java8lambda库中，如Guava，输出使用常见的Java框架接口，因此很容易将它们传递给外部/内部API，如果库方法这样做，仍然可以利用一些懒惰的计算(例如懒惰filter()和transform())。
但是，在Java 8流中，获取Collection/Map的调用是终端(即急切)，它还将分配新的数据结构来保存结果。
对于中间有多个阶段和策略模式的复杂计算，由于中间结果导致了大量不必要的分配。
那么，人们是否认为采用并返回Streams是内部API(即策略模式策略)的一个好做法，还是应该让我回到懒散但不是流线型的番石榴API(我想是双关语)？
编辑：
我对Stream的主要
浏览 0提问于2015-07-13得票数 14
回答已采纳
2回答
Java TCP FIN但没有
、、、、
我一直在使用org.apache.commons.net.telnet连接到控制流并向摄像机发送命令。我发送一个数据传输请求并打开一个新线程，该线程从摄像机的传感器扫描图像，并将数据作为原始字节发送给我。我使用标准的java.io instream和outstream来读取。我写到一个文件的外部.只是原始字节。但是，我被困在一个无限循环中，读取套接字发送的数据。instream.read() > -1把我留在那里.我已经做了instream.available() > 0，但是这常常会缩短图像(这是可以理解的)。我甚至尝试过各种和/或，永远无法得到一个完整的阅读。
我在Wiresh
浏览 0提问于2016-01-04得票数 0
回答已采纳
在我的mule流中，我使用WMQ节点读取消息表单WMQ，然后使用Java节点调用Java类以处理所需的消息。
同样，我必须重写公共对象transformMessage(MuleMessage message，String outputEncoding)方法。此方法迫使我返回值，但不需要将任何对象发回。
有人能帮助我理解我需要返回的东西，以及为什么我们必须返回价值吗？
干杯!
浏览 2提问于2014-11-07得票数 0
回答已采纳
我想知道Java中flush和close函数的确切区别是什么？
在写入文件期间，数据何时被转储到文件中？
请举一个例子
浏览 2提问于2012-02-14得票数 55
回答已采纳
我想用一个拥有大量数据的HTTP客户机来测试我们的应用程序。是否可以使用WireMock创建无限或几千兆字节的输出，而无需分配这样大小的字节数组或字符串？
据我所见，
public ResponseDefinitionBuilder withBodyFile(String fileName)
public ResponseDefinitionBuilder withBody(String body)
public ResponseDefinitionBuilder withBody(byte[] body)
我尝试过withBodyFile("/dev/zero&#
浏览 2提问于2019-02-04得票数 3
考虑到我的应用程序在inbound中运行为8.5.5.9，通过WebSphere连接到WebSphere MQ7.0(通过JNDI解决)，使用(4.2.5)入站网关配置如下：
<int-jms:inbound-gateway id="requestGateway"
connection-factory="jndiConnectionFactory"
request-destination="jndiQueueInput"
浏览 1提问于2016-05-19得票数 0
回答已采纳
1回答
我在(标准运行时)上托管了一个项目。我已经定义了一个servlet，它用高达200 up的数据响应GET请求。问题是servlet试图在实际写入之前缓冲大量数据。
我试着给缓冲设定上限，
resp.setBufferSize(1024);
但这没什么区别。缓冲区大小的即时日志，
LOGGER.info("Using buffer of size " + resp.getBufferSize());
告诉我缓冲区的大小是1024，但是一旦数据被写入，我再次记录缓冲区的大小，根据所写的数据，它已经增长到非常大的数量。
现在，如果我将输出增加到足够大的数量，我就会得到一个异常，同时写
浏览 2提问于2016-07-12得票数 0
回答已采纳
我使用jackson框架对JSON和Java之间的数据进行编组和解组。所有操作都很好，只要输入不包含任何字符，比如：
舍尔
ä
ü
奥兹
艾尔
U.
二.二
对于输入数据，我尝试：
String jsonData = "{\"id\":1,\"street\":\"Straße\",\"number\":\"1c\",\"zipCode\":1111,\"city\":\"MyCity\"}";
以及：
String
浏览 1提问于2013-08-11得票数 11
回答已采纳
1回答
关于骡子中的变量，我没有几个问题。
如果我有如下的有效载荷，
在Groovy脚本中访问这些信息的最好方法是什么？#有效负载似乎不起作用.
<scripting:script engine="Groovy">
...
qr.update(conn, "INSERT INTO event values(#[payload], 1)");
..
</scripting:script>
如何将一个值从流中的一个特定点存储到一个变量中，以便在以后的任何时候使用它。
如果我有string类型的有效负载，并且需要使用自定义jav
浏览 0提问于2013-02-22得票数 0
回答已采纳
获取org.tukaani.xz.CorruptedInputException:提取7z文件时压缩数据损坏错误。我使用common-compress-1.21.jar和xz-1.9.jar. File f = new File("/home/local/Documents/7zFile/7zFile.7z");
InputStream inputStream;
ArchiveEntry entry = null;
try {
inputStream = new FileInputStream(f);
} catch (
浏览 201提问于2021-09-06得票数 0
回答已采纳
1回答
异常复制流的有效载荷
、、、、
我很难修复这个stuffs.The设置，我实现了Camera.PreviewCallback对象的onPreviewFrame方法，通过帧字节获取要发送到连接设备的数据。
Camera.PreviewCallback previewCallback= new Camera.PreviewCallback() {
@Override
public void onPreviewFrame(byte[] bytes, Camera camera) {
Log.e(TAG, "onPreviewFrame: BYTE SIZE: "+bytes.to
浏览 0提问于2018-02-27得票数 0
我有一个从std中读取数据的java类。当我使用java任务从ant运行这个类时，ANT挂起，不显示输入提示，也不接受来自命令行的输入。它就挂在那里。如果我使用shell脚本运行相同的类，它可以工作。
有人知道蚂蚁为什么要这么做吗？我已经尝试将fork (在java任务上)设置为true和false。两种方法都不起作用。
浏览 5提问于2011-02-19得票数 2
回答已采纳
我试图从db中获取数据，为每条记录逐个从db进行映射和上传到云。我所做的工作如下：
从db中选择数据，从db映射每个记录，然后上传。
骡子流：
<flow name="psi2sfdcFlow2" doc:name="psi2sfdcFlow2">
<http:inbound-endpoint exchange-pattern="request-response" host="${hostname}" port="${port}" path="psi2sfdc" doc:n
浏览 9提问于2015-06-17得票数 1
回答已采纳
1回答
我正在尝试加载较大的位图。
我读到了这个：
我尝试从字符串创建相同的方法
public static Bitmap decodeSampleBitmapFromStream(InputStream is, int reqWidth, int reqHeight){
// First decode with inJustDecodeBounds=true to check dimensions
final BitmapFactory.Options options = new BitmapFactory.Options();
options.inJustDec
浏览 0提问于2013-06-18得票数 0
回答已采纳
1回答
我将如何通过互联网将音频从一个设备传输到另一个设备？我知道使用Java套接字发送基本数据，但不知道如何：
开始在文件的中间流(例如，在歌曲的中间)
发送的数据需要什么样的格式。MediaPlayer可以将url作为数据源，那么当从服务器端发送音频时，应该如何表示？
谢谢
浏览 6提问于2016-11-01得票数 2
我有一个回调，它以FloatBuffer的形式接收传入的音频数据，其中包含1024个浮点数，每秒调用几次。但是我需要一个AudioInputStream，因为我的系统只和它们一起工作。
将浮点数转换为16位PCM音频数据并不是问题，但我不能用它创建一个InputStream。AudioInputStream构造函数只接受已知长度的数据，但我有一个常量流。如果我向AudioSystem.getAudioInputStream提供包含音频数据的PipedInputStream，则它会抛出一个"java.io.IOException: mark/reset不受支持“。
有什么想法吗？
以下
浏览 4提问于2018-04-10得票数 1
回答已采纳
2回答
MPEG-TS PSI解析
、、、、
我正在尝试构建中指定的EIT表节。我已经成功地将数据包解析成数据结构(在Java中)，并且可以访问每个数据包的有效负载。
我不明白表部分是如何在数据包中被分割的，规范有点混乱/不确定。假设可以通过PID过滤TS数据包流，那么构建这样一个表的过程是什么？
我理解正在设置的payload_unit_start_indicator，表示有效负载字段的第一个字节是指向新部分的第一个字节的指针，这是与有效负载开始时的偏移量吗？
例如，如果我收到一个TS数据包，并将它标识为节的开始，那么我是否将字节读取到数组中，从标头中确定节长度，然后将越来越多的相同PID的TS数据包有效负载填充到中？
谢谢你的阅读，任
浏览 10提问于2014-08-06得票数 3
1回答
为什么当我试图写入输出流时套接字会关闭？
堆栈跟踪：
Exception in thread "main" java.lang.RuntimeException: java.net.SocketException: Socket is closed
at chatx.server.handler.ExceptionHandler.handle(ExceptionHandler.java:14)
at chatx.server.handler.ExceptionHandler.handle(ExceptionHandler.java:6)
at chatx
浏览 0提问于2018-07-03得票数 0
回答已采纳
1回答
我正面临着骡子测试的问题。我只是尝试了一个简单的功能测试示例。以下是我的流程
<flow name="muletestFlow1" doc:name="muletestFlow1">
<http:inbound-endpoint exchange-pattern="request-response" host="localhost" port="8081" path="test" doc:name="HTTP"/>
<r
浏览 4提问于2014-12-31得票数 0
回答已采纳
2回答
我有两个后台进程运行在linux机器上。一个是Java，第二个是Python。在这两个应用程序之间进行交换数据的最有效方法是什么？我指的是<10 am下面的文本/图像数据，大约每5分钟一次(不是流)。由于重构的成本很高，我们无法完全迁移到Python (或Java)。
当然选择是文件系统或本地网络，但是在内存数据库(sqllite/redis/.)中呢？文件系统处理或网络处理有时是痛苦的，我想。
您认为内存中的-DB对于这样的任务是很好的选择吗? Jython不是选项，因为并不是所有的库都兼容.
环境: ubuntu服务器12.04 64位，Python2.7，Java 7
浏览 3提问于2013-05-08得票数 1
回答已采纳
1回答
我想用jt400.jar为Java中使用的一个简单的"name->blob“结构建模(本质上是在数据库中而不是IFS中存储大的、不变的文件)，这很容易用一个
CREATE TABLE TRATEST/X (NAME VARCHAR (256 ) NOT NULL WITH
DEFAULT, BLOB BLOB NOT NULL WITH DEFAULT, BLOBPART INT NOT NULL
WITH DEFAULT)
(由于F4使用导致的冗长)，它创建了一个文件X，看起
浏览 1提问于2012-12-03得票数 1
我有一个需求，其中web服务的请求有效负载必须在路由中的多个活动中使用。在我的特定案例中，传入的请求用于执行两个xsl转换。为了能够访问原始有效负载，我尝试将其放入报头中，但一旦尝试在有效负载上设置报头，它就会抛出与START_ELEMENT / END_ELEMENT相关的异常
我的路线：
<camelContext id="camel" xmlns="http://camel.apache.org/schema/spring">
<route id="loadGlobalVars">
<c
浏览 0提问于2018-04-18得票数 0
1回答
当使用httpclient获得响应时，我在out.write(EntityUtils.toString(resEntity)); //它是java代码中的第70行时得到了一个错误
为什么会发生这种事？
CloseableHttpClient httpClient = HttpClients.custom().setUserAgent("Mozilla/5.0 (Windows NT 6.3; rv:36.0) Gecko/20100101 Firefox/36.0").build();
HttpResponse response = httpClient.exe
浏览 4提问于2015-08-07得票数 6
回答已采纳
1回答
我安装了最新版本的ESB (2.4.1)和WSO2 WSO2 (4.8.1)。ESB中的BAM中介器不工作。每次尝试向BAM发送消息时，它都会抛出下面的异常。
你能帮帮忙吗？
[2014-09-15 05:54:58,833] ERROR - AsyncDataPublisher Error occurred while finding | defining the event org.wso2.carbon.databridge.agent.thrift.exception.AgentException: Cannot define type {"streamId":"
浏览 3提问于2014-09-15得票数 3
我在pre Java 8中有一个要遍历的嵌套列表。我的例子非常类似于loop through nested list in java 8，这是一个很好的例子，然后我意识到我需要为每个list检查null。请参考下面的例子。如果满足最后一个条件，则通过短路返回true。 但是，我不确定如何使用list.stream().flatMap()检查每个list的null。 for(A a : ListA) {
if(a.getListB() != null && !a.getListB().isEmpty()) {
for(B b : a.ge
浏览 39提问于2020-04-17得票数 0
回答已采纳
我用过video_player: ^0.10.1+2，它在IOS上运行良好，但在安卓上不起作用。 _videoPlayerController1 = VideoPlayerController.network('url with .m3u8 file');
_chewieController = ChewieController(
videoPlayerController: _videoPlayerController1,
//aspectRatio: 3 / 2,
//aspectRatio: _videoPlayerController1
浏览 321提问于2019-06-05得票数 5
我需要发送一些post数据和一个文件流。我使用以下代码。
这段代码取自。
private Stream GetPostStream(string filePath, Dictionary<string, string> paramMap, string boundary) {
Stream postDataStream = new System.IO.MemoryStream();
//adding form data
string formDataHeaderTemplate = Environment.NewLine + &#
浏览 7提问于2012-04-27得票数 0
3回答
我当前正在尝试让我的服务器创建与客户端的连接。我已经为每个连接创建了一个线程，但是服务器当前没有创建输入流。我通过打印数字来测试这一点，但只有1和2被打印出来。我确信这只是我遗漏的一个小问题。
public class ObjectHandler implements Runnable{
Socket sock;
ObjectInputStream ois;
ObjectOutputStream oops;
InputStream is;
public ObjectHandler(Socket clientSocket) throws IOExcep
浏览 4提问于2012-03-23得票数 0
回答已采纳
2回答
这是一个相当简单的任务，我已经做了很多次。但是，目前，我被困在这条琐碎的代码行中。
import java.io.File;
import java.io.FileNotFoundException;
import java.util.Scanner;
public class Test {
private static Scanner scan;
public static void main(String[] args) throws FileNotFoundException {
// TODO Auto-generated method stub
File f
浏览 2提问于2016-04-21得票数 1
回答已采纳
我有一个JSON (来自流)。数据是巨大的。因此，我不希望反序列化为具体的Java对象。所以我想用杰克逊解析器。
JsonFactory factory = new JsonFactory();
JsonParser parser = factory.createJsonParser(stream);
我的目标是从流中获取特定的部分(来自对象的特定属性)
{
"array": [],
"map": {},
"bool": "true",
"string": "abcd&#
浏览 5提问于2015-10-26得票数 1
1回答
上传结束点在多部分文件中从客户端接收数据.此文件再次作为参数发送到来自同一服务的新HTTP调用。
//客户端上传文件代码
form(enctype="multipart/form-data", action="/data/upload", method="post")
input(type="file", name="data")
我想读取该文件并将其上传到另一个接受该文件的Java端点。
我尝试通过busBoy获取文件流，并将其转换为字符串，并尝试将字符串转换回流并将其传递给新请求。但是Java服务失败了。
浏览 2提问于2020-11-20得票数 0
1回答
非GZIP格式Java
、、、
我正在尝试从网上下载.torrent文件。一些在线文件是压缩(gzipped)格式。我知道我可以用以下代码解压缩这些文件：
try (InputStream is = new GZIPInputStream(website.openStream())) {
Files.copy(is, Paths.get(path));
is.close();
}
但是有些.torrent文件没有被压缩，因此我得到了错误消息：
java.util.zip.ZipException: Not in GZIP format
我正在处理一个大型的.torrent文件数
浏览 2提问于2014-03-01得票数 4
回答已采纳
java.sql.SQLException: could not reset reader
at org.hibernate.lob.ClobImpl.getCharacterStream(ClobImpl.java:100)
at org.hibernate.type.ClobType.set(ClobType.java:70)
at org.hibernate.type.ClobType.nullSafeSet(ClobType.java:141)
at org.hibernate.persister.entity.Abstr
浏览 1提问于2011-10-03得票数 4
我在客户端有一个xml数据。我把它发送到服务器。然后在服务器中进行处理。但是我得到了一个致命的错误。以下是javascript代码：
console.log($.isXMLDoc(xmlData)); // prints true
$.ajax({
url: 'foo.bar'
, processData: false
, data: xmlData
, success: function(data){
}
});
和我的java代码：(它处理xml数据)
try {
浏览 1提问于2010-08-25得票数 2
假设这个Java流的使用场景，其中数据是从数据源添加的。数据源可以是一个值列表，如下面的示例所示，也可以是一个分页的REST。这不重要，现在。
import java.util.List;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.stream.Stream;
public class Main {
public static void main(String[] args) {
final List<Boolean> dataSource = List.of(tr
浏览 1提问于2019-06-05得票数 2
回答已采纳
我的管道通过GCS通过Pub\Sub方式读取数据，然后将数据汇到redis。一开始，它在Dataflow中运行得很好。但是，在两天后运行后，在我的管道中发现了以下异常。
java.lang.NoClassDefFoundError: Could not initialize class org.xerial.snappy.Snappy
org.xerial.snappy.SnappyOutputStream.<init>(SnappyOutputStream.java:97)
org.xerial.snappy.SnappyOutputStream.
浏览 1提问于2019-09-02得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
