-
Updated
Aug 19, 2020
stream-processing
Here are 608 public repositories matching this topic...
-
Updated
Aug 11, 2020 - Java
-
Updated
Aug 19, 2020 - Python
Describe the bug
A clear and concise description of what the bug is.
KSQLDB fails to start if ssl.keystore.type=pkcs12 instead of ssl.keystore.type=PKCS12
To Reproduce
Steps to reproduce the behavior, include:
- The version of KSQL.
- Sample source data.
- Any SQL statements you ran
Latest version of KSQLDB with Java 11 and FIPS support enabled.
Expected behavior
A
-
Updated
Aug 16, 2020
-
Updated
Aug 23, 2020 - Go
-
Updated
May 1, 2019 - C
-
Updated
Aug 23, 2020 - C
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
-
Updated
Aug 22, 2020 - Go
-
Updated
Aug 23, 2020
-
Updated
Aug 14, 2020 - Python
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:
- We can't just use
@printflike we have been until now. We need to either include a timestamp in every@printfcall (laborious and error prone) or c
-
Updated
Aug 23, 2020 - Java
-
Updated
Aug 11, 2020 - Java
-
Updated
Aug 21, 2020 - JavaScript
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
-
Updated
Aug 18, 2020 - Scala
-
Updated
Aug 23, 2020 - Java
-
Updated
Aug 6, 2020 - Java
-
Updated
Mar 29, 2020 - Go
-
Updated
Aug 20, 2020 - TypeScript
-
Updated
Mar 31, 2018
-
Updated
Sep 16, 2017 - Go
-
Updated
Jul 9, 2020 - Go
-
Updated
Dec 22, 2019
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 :)
Improve this page
Add a description, image, and links to the stream-processing topic page so that developers can more easily learn about it.
Add this topic to your repo
To associate your repository with the stream-processing topic, visit your repo's landing page and select "manage topics."


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