Chris Lu

wow, this is a great idea!!! Maybe limit the args to a JSON object, for easier serialization and deserialization?

try to add some actual work between read and println.

connect to some real kafka topic. There are some buffers. If not much traffic, the data are buffered.

works for me though.

Currently not ready, but sounds an interesting use case.

1. already support socket 2. added in https://github.com/chrislusf/gleam/commit/c0132073d3f8a06a2bf3e080f3b504b148f438c2 3. not yet. Should be simple to add if you have an account to test it out. See this introduction on how...

stateless

This is not supported yet. This can be done by extending Mapper and Reducer, returning a few initialization/cleanup functions. And then in gio/mapper.go and gio/reducer.go, calling those functions. I will...

I would like to know any existing Golang API to connect to Hive.

This hive lib can query, but in a streaming way. Ideally something can do concurrent queries.