Elizabeth Bennett

I suppose the main limitation is that there are only 255 locks/segments, so blocking on loading one key would unnecessarily block reads/writes for other keys unless we have a lock...

FWIW I was able to get this working by using this as my test runner: ```javascript class UnauthorizedError { constructor(msg){ console.log(msg); } getMsg() { return this.msg; } } const sandBox...

This is actually an issue with the httpclient version. After sleuthing around the classpath and maven dependency tree, it appears that the aws-java-sdk-s3 dependency, which in streamx is currently set...

Thanks for your reply @PraveenSeluka. I'm not able to use NativeS3FileSystem because it doesn't support aws's temporary security credentials, which is what I'm using. There is a [ticket open](https://issues.apache.org/jira/browse/HADOOP-9680) in...

Regarding the S3 403 error, I resolved that by deleting the access_key and secret_key configs from the hadoop hdfs-site.xml config file. Streamx seems to be working smoothly now. Really the...

Kafka Streams for Python would be so amazing. I'm currently evaluating stream processing frameworks and I like what I've been reading about Kafka Streams. My use case is essentially this:...

Thanks for your reply @miguno and thanks for the suggestions. Jython might be a good option for prototyping. I may actually be able to drum up support for Scala based...

@murphyke that would be super. I actually just created a repo last weekend to start working on it (https://github.com/python-kafka-streams/python-kafka-streams). I haven't committed any work or created any tickets yet, but...

Sure. Initially, the data was going to a 5 shard index, which is the default size for indexes in ES. I bumped up the size of the index to 30...

This would be really useful. I'm wondering how to implement this without adding dependencies on a bunch of AWS libraries that most people will not need or want on their...