clear query| facets| time Search criteria: .   Results from 1 to 10 from 15 (0.0s).
Loading phrases to help you
refine your search...
[FLUME-3314] Flume kafka source/channel throws NPE when migrateOffsets() is called on nonexistent topics - Flume - [issue]
...KafkaConsumer.partitionsFor(topicStr) returns null if the topic does not exist and auto.create.topics.enabled has been set to false on Kafka side.This case is not handled in the Flume code w...    Author: Peter Turcsanyi , 2019-02-07, 14:26
[FLUME-3316] Syslog Rfc3164Date test fails when the test date falls on a leap day - Flume - [issue]    Author: Peter Turcsanyi , 2019-01-31, 14:49
[FLUME-3271] Update User Guide to follow log4j2 upgrade changes - Flume - [issue]
...Flume logging has been upgraded from logj4 1.2.x to 2.x (FLUME-2050), but the User Guide has not been updated with these changes.Eg.: -Dflume.root.logger=INFO,console does not work any more...    Author: Peter Turcsanyi , 2019-01-03, 10:15
[FLUME-3307] Get rid of the reflection calls in AbstractHDFSWriter - Flume - [issue]
...AbstractHDFSWriter uses some HDFS client calls through reflection in order to retrieve the default / current replication count and also to determine if the client supports hflush() or only s...    Author: Peter Turcsanyi , 2018-12-18, 08:51
[VOTE] Release Apache Flume version 1.9.0 RC2 - Flume - [mail # dev]
...Hi All,I have manually tested the RC2 package: download, checksum check, untar,run some basic flows with commonly used sources/sinks (jms source, kafkasource/channel/sink, spool/taildir sour...
   Author: Peter Turcsanyi , 2018-12-12, 14:55
[FLUME-3294] Fix polling logic in TaildirSource - Flume - [issue]
...TaildirSource.process() always returns Status.READY and sleeps inside the method. It should return Status.READY / Status.BACKOFF and this status would control the common backoff sleepin...    Author: Peter Turcsanyi , 2018-11-22, 22:34
[DISCUSS] Flume 1.9 release proposal - Flume - [mail # dev]
...Hi Ferenc,+1Please let me know if I can help you in any way.At the moment I am working on FLUME-3133 (PR is expected tomorrow) whichcan be added to the release too.Then I will continue with ...
   Author: Peter Turcsanyi , 2018-11-07, 10:27
[FLUME-3278] Handling -D keystore parameters in Kafka components - Flume - [issue]
...FLUME-3269 introduced -D SSL system properties to configure the keystore/truststore parameters of Flume components.It turned out that Kafka client does not handle -D keystore parameters dire...    Author: Peter Turcsanyi , 2018-11-01, 19:11
[FLUME-3269] Support JSSE keystore/trustore -D system properties - Flume - [issue]
...Several Flume components support SSL, but they all have their own config parameters for specifying the location and password for keystore and truststore.These parameters could be passed as s...    Author: Peter Turcsanyi , 2018-10-05, 11:20
[FLUME-3270] Close JMS resources in JMSMessageConsumer constructor in case of failure - Flume - [issue]    Author: Peter Turcsanyi , 2018-09-06, 06:30