André Caron
André Caron
**TL; DR**: it would be convenient in some rare cases to allow providing our own timestamp. Right now, I need to reimplement `structlog.processors.TimeStamper` to do achieve this. I'm writing a...
Hi there! Thanks for this awesome plug-in! I noticed that Flume sources using this plug-in do not appear in the flume metrics page. Is there any chance this can be...
Hi there, Thanks for this awesome plug-in! I've been trying to inject fields like the source and environment names for our deployment via the Flume configuration using interceptors, but it...
Hey there! This is more of a question than an issue :-) Some of the classes that I'm trying to migrate to attrs have attributes that are expensive to compute....
Hi there! I have a few programs where I use condition variables and while experimenting with gevent, I noticed that it has implementation for semaphores and events, but not for...
Hi there :-) I hope I'm reporting this to the right place, let me know if this isn't it. I noticed there is support for UNIX sockets in asyncio, but...
I'm following the `RangedIntSchemaNode` example under [Subclassing SchemaNode](http://docs.pylonsproject.org/projects/colander/en/latest/basics.html#subclassing-schemanode) and it works (provided you add a `schema_type` class attribute), but I can't get it to work for sequences. For example: ```...
I'm working on some minor contributions to the ElasticSearch sink and I noticed that `mvn install -pl flume-ng-sinks/flume-ng-elasticsearch-sink` fails out of the box due to issues reported by SpotBugs. In...
When using `.client = rest`, the `.clusterName` argument is never used. It should be optional in this case.
ElasticSearch provides support for deduplication of events using the `_id` field when inserting documents using the bulk insert facility. When using the UUID interceptor with `headerName = _id` for this...