Hello, dear Mediapipe guys.

I want to inference the hand pose with Mediapipe model and my own model.

I have my own tf-lite models, it can work on the RGB bitmap.

I try to query the RGB bitmap from input frame with data packet.

My code is

private static final String INPUT_VIDEO_STREAM_NAME = "input_video";
processor.addPacketCallback(INPUT_VIDEO_STREAM_NAME, (packet)->{
 

Running : CLI v0.11.0, Server v0.11.0
(pulled from confluentinc/ksqldb-server:0.11.0)

Creating a stream with a field named "size" results in the following error :
extraneous input 'size' expecting {'EMIT'

It seems like size is considered a reserved keyword.
Creating the stream with CREATE STREAM trades ( "size" DOUBLE ) works.

Looks similar to https://github.com/confluentinc/ksql/issu

Currently, you are not able to use middleware per handler in "clean way" (you can still manually wrap the handler function, or have separated router).

It would be nice to be able to add middleware per handler.

As a good reference point, you can use chi router: https://github.com/go-chi/chi

It can be very difficult to piece together a reasonably estimate of a history of events from the current workers logs because none of them have timestamps.

So for that end, I think we should add timestamps to the logs.

This has some cons:

1. We can't just use @printf like we have been until now. We need to either include a timestamp in every @printf call (laborious and error prone) or c

For example, given a simple pipeline such as:

Pipeline p = Pipeline.create();
p.readFrom(TestSources.items("the", "quick", "brown", "fox"))
 .aggregate(aggregator)
 .writeTo(Sinks.logger());

I'd like aggregator to be something requiring a non-serialisable dependency to do its work.

I know I can do this:

Pipeline p = Pipeline.create();
p.readFrom(TestSource

All exceptions in namespace JsonMachine\Exception should extend one common exception, say JsonMachineException, so that userland code can catch for only one type and catch anything from this library. Fell free to create pull request and participate :)