-
Updated
Oct 30, 2020 - Python
kafka-streams
Here are 511 public repositories matching this topic...
-
Updated
Nov 8, 2020 - Java
-
Updated
Apr 12, 2020 - Java
-
Updated
Sep 19, 2020 - Python
-
Updated
Nov 6, 2020 - Shell
-
Updated
Oct 13, 2020 - Java
-
Updated
Oct 12, 2020 - Java
-
Updated
Oct 2, 2020 - TypeScript
-
Updated
Oct 14, 2020 - Go
-
Updated
Oct 19, 2020
-
Updated
Nov 12, 2019 - Scala
Catch all is right now pushing error to sentry. Would like to publish the same to new relic as well. Planning to use noticeError
provided by newrelic java agent.
-
Updated
Oct 13, 2020 - Java
Is your feature request related to a problem? Please describe.
Some areas of the web portal have issues with screen readers. Here are a few examples
Describe the solution you'd like
Improve readability for screen readers across the web portal
-
Updated
May 30, 2019 - Scala
-
Updated
Jul 20, 2018 - Scala
-
Updated
Jul 19, 2020 - Scala
-
Updated
Nov 5, 2020 - Jupyter Notebook
-
Updated
Nov 4, 2020 - Java
-
Updated
Oct 13, 2020 - Java
Currenlty a StreamsExecutionEnvironment
instance can be registed directly through the AzkarraContext#addExecutionEnvironment
method and from the configuration.
The following example shows how to define an environment using configuration :
azkarra {
// Create a environment for running the WordCountTopology
environments = [
{
name: "dev"
config = {}
jo
The sum and count Kafka tutorials instruct the user to create a directory called aggregate-
, whereas the actual folder for them in GitHub are called aggregating-
.
There is no functional impact to current behavior (it still works) but it would be better to be consistent.
-
Updated
Sep 30, 2020
-
Updated
Nov 12, 2019 - Java
-
Updated
Oct 27, 2020 - Java
-
Updated
Dec 15, 2017 - Clojure
-
Updated
Oct 28, 2020 - Java
-
Updated
Jul 29, 2020 - Java
Improve this page
Add a description, image, and links to the kafka-streams topic page so that developers can more easily learn about it.
Add this topic to your repo
To associate your repository with the kafka-streams topic, visit your repo's landing page and select "manage topics."
Add some integration tests including the use of an avro schema registry