Unsubscribe
Sent from my iPhone
-
To unsubscribe, e-mail: user-unsubscr...@spark.apache.org
For additional commands, e-mail: user-h...@spark.apache.org
Hello community,
I am running a simple consumer for kafka such as this
int timeout = 8;
int bufferSize = 64*1024;
consumer = new SimpleConsumer(host, port,timeout, bufferSize, clientName);
This runs fine for a couple for hours but I get an exception later on
kafka.consumer.SimpleCo
’t pursue it beyond some high level design work.
You could open a JIRA for this feature request.
Thanks, Aaron
From: Shivpriya Tamboskar
mailto:shivpriya_tambos...@symantec.com>>
Reply-To: "user@storm.apache.org<mailto:user@storm.apache.org>"
mailto:user@storm.apache.org
Hello,
I am trying to write data into HDFS using the storm-hdfs bolt
http://storm.apache.org/documentation/storm-hdfs.html
The problem I am trying to solve is that I want the file paths to be set
according to the input tuples.
FileNameFormat fileNameFormat = new DefaultFileNameFormat()