-
Updated
Jan 29, 2022 - Python
kafka-streams
Here are 721 public repositories matching this topic...
-
Updated
Mar 19, 2022 - Java
Describe the bug
On the brokers page we have 6 brokers specified but only 6 hosts are returned. broker 1 (b-1.xxx) is missing.
Set up
Docker image is on the latest using very basic config with only broker links specified with READ_ONLY = true.
Steps to Reproduce
Steps to reproduce the behavior:
- Specify 6 brokers in the configuration
- Start the app
- See that the b
-
Updated
Apr 12, 2020 - Java
-
Updated
Mar 10, 2022 - Shell
-
Updated
Mar 10, 2022 - Python
-
Updated
Feb 11, 2022 - Go
-
Updated
Nov 26, 2020 - Java
-
Updated
Feb 27, 2022 - TypeScript
-
Updated
Oct 12, 2020 - Java
-
Updated
Dec 21, 2021
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.
Add some integration tests including the use of an avro schema registry
-
Updated
Nov 12, 2019 - Scala
-
Updated
Oct 13, 2020 - Java
-
Updated
Nov 5, 2020 - Jupyter Notebook
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.
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
use gitpod
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
May 30, 2019 - Scala
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 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 7, 2021 - Java
-
Updated
Mar 5, 2022 - Java
-
Updated
Jan 24, 2022
-
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."
Bug description
Header in
Top Endpoint
section overflows in browser with reduced widthExpected behavior
Header shouldn't overflow
How to reproduce
Version information