The Wayback Machine - https://web.archive.org/web/20220706223555/https://github.com/topics/kafka-streams
Skip to content
#

kafka-streams

Here are 758 public repositories matching this topic...

kafka-ui
armenuikafka
armenuikafka commented Jul 4, 2022

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:

  1. Navigate to Topics
  2. Edit a Topic
  3. Change the value of "Replication Factor * " field to be < = 0

Expected behavior
Could be better to have information:

type/enhancement good first issue scope/backend status/accepted

This project contains examples which demonstrate how to deploy analytic models to mission-critical, scalable production environments leveraging Apache Kafka and its Streams API. Models are built with Python, H2O, TensorFlow, Keras, DeepLearning4 and other technologies.
  • Updated Nov 26, 2020
  • Java
memgraph
antonio2368
antonio2368 commented Jan 4, 2022

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'
good first issue

Real Time Big Data / IoT Machine Learning (Model Training and Inference) with HiveMQ (MQTT), TensorFlow IO and Apache Kafka - no additional data store like S3, HDFS or Spark required
  • Updated Nov 5, 2020
  • Jupyter Notebook
carlbrochu
carlbrochu commented Apr 18, 2019

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

enhancement help wanted good first issue
azkarra-streams
fhussonnois
fhussonnois commented May 12, 2020

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
type:enhancement good first issue in:runtime

Improve this page

Add a description, image, and links to the kafka-streams topic page so that developers can more easily learn about it.

Curate this topic

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."

Learn more