xitep
xitep
`KafkaClient` maintains a connection to each explored kafka broker. When sending or fetching messages the communication to these brokers happens synchronously. Example 1: when delivering a bunch of messages to...
Consumer should allow its clients to reset/seek its offset. This allows repeated runs over a topic's data (for testing purposes for example).
Client code can supply a list with way too many messages to be sent at once, leading to Kafka rejecting the "produce_message" response entirely. `Producer` shall be able to deal...
`examples/topic-metadata` prints for example: ``` > ./topic-metadata --brokers host:port --topics topic-name topic p-id l-id (l-host) earliest latest (size) topic-name 0 1 (xxx.xxx.xxx.xxx:port) 7261198 7261198 (0) topic-name 1 2 (xxx.xxx.xxx.xxx:port) 7328851...
We shall actively close inactive/idle connections as soon as possible to prevent brokers closing them first. In particular, we'd like to actively close idle connection as soon as possible _after...
`kafka-rust` currently does a poor job of handling errors. It basically pushes all the responsibility to client code. However, that client code's only option, is to reload metadata and to...
Potential users are confused about how Euphoria compares to Apache Beam and what its feature set is. Please create a page in the wiki describing the set of supported features...
This is merely a parent ticket to track efforts on improving documentation. In particular, we'd like to: * Provide human friendly documentation, tutorials, conceptual explanations in the form of the...
As part of #98 we disabled the experimental support for object re-use on the flink executor. We would like to reintroduce it again with the corresponding problems resolved. Part of...
Execution engines can do much better at optimizations if they transparently know what types they are working with. Efforts in the [Spark](https://jaceklaskowski.gitbooks.io/mastering-apache-spark/content/spark-sql-tungsten.html) as well as the [Flink](https://flink.apache.org/news/2015/05/11/Juggling-with-Bits-and-Bytes.html) community proof optimization...