-
Updated
Jun 7, 2022 - Python
kafka-streams
Here are 758 public repositories matching this topic...
-
Updated
Jul 6, 2022 - Java
-
Updated
Apr 12, 2020 - Java
-
Updated
Jul 1, 2022 - Shell
-
Updated
Jun 27, 2022 - Python
-
Updated
Jun 1, 2022 - Go
-
Updated
Nov 26, 2020 - Java
-
Updated
Jun 2, 2022 - TypeScript
-
Updated
Jul 1, 2022 - Java
-
Updated
Dec 21, 2021
CASE doesn't work well with null. This works as expected and prints 'works':
WITH 2 AS name
RETURN CASE name
WHEN 2 THEN 'works'
WHEN null THEN "doesn't work"
ELSE 'something went wrong'
END
If we swap the first case from 2 to 3. It should print 'something went wrong', but instead it prints "doesn't work":
WITH 2 AS name
RETURN CASE name
WHEN 3 THEN 'works'
-
Updated
Jul 6, 2022 - Clojure
Use Case
- Provide a sample application to test DBs, messaging systems and HTTP, GRPC backend resolution and call view.
Proposal
- A simple app where backend can be swapped or we can use multiple backends.
Add some integration tests including the use of an avro schema registry
-
Updated
Nov 12, 2019 - Scala
-
Updated
May 20, 2022 - Java
-
Updated
Nov 5, 2020 - Jupyter Notebook
Is your feature request related to a problem? Please describe.
Today the user needs to deploy udf jars and reference data csvs manually to the blob location
Describe the solution you'd like
Enable the user to choose a file on a local disk which the web portal will then upload to the right location
https://developer.confluent.io/tutorials/creating-first-apache-kafka-producer-application/confluent.html
https://developer.confluent.io/tutorials/creating-first-apache-kafka-consumer-application/confluent.html
These tutorials don't use Avro (they produce/consume String
keys and values), so the build.gradle file can be simplified
-
Updated
May 30, 2019 - Scala
-
Updated
Jul 20, 2018 - Scala
-
Updated
Jan 16, 2021 - Scala
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
-
Updated
Jun 20, 2022 - Java
-
Updated
Jun 16, 2022 - Java
-
Updated
Jan 24, 2022
-
Updated
Jun 22, 2022 - TypeScript
-
Updated
Jan 7, 2022 - 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."
Describe the bug
Could be better to have validation message about accepted value for Replication Factor * field
Set up
https://www.kafka-ui.provectus.io/
Steps to Reproduce
Steps to reproduce the behavior:
Expected behavior
Could be better to have information: