-
Updated
Jun 24, 2021 - Python
kafka-streams
Here are 618 public repositories matching this topic...
-
Updated
Aug 17, 2021 - Java
-
Updated
Apr 12, 2020 - Java
-
Updated
Aug 10, 2021 - Python
-
Updated
Jul 30, 2021 - Shell
-
Updated
Nov 26, 2020 - Java
-
Updated
Jun 25, 2021 - Go
-
Updated
Aug 12, 2021 - TypeScript
-
Updated
Oct 12, 2020 - Java
Add replicas field in partitions table at topic overview page.
We can get list of replicas from topic request endpoint: /clusters/{clusterName}/topics/{topicName}
{
"name": "name",
"internal": true,
"partitions": [
{
"partition": 0,
"leader": 2,
"replicas": [
{
"broker": 2,
-
Updated
Jul 27, 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
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
-
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.
-
Updated
May 30, 2019 - Scala
-
Updated
Jul 20, 2018 - Scala
-
Updated
Jan 16, 2021 - Scala
wrt existing tutorial at https://kafka-tutorials.confluent.io/how-to-count-messages-on-a-kafka-topic/ksql.html
Add limitation that when there are a large number of records in the topic (i.e., hundreds of millions of records), this query can take a very long time to finish (i.e., tens of minutes, sometime few hours)
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
Aug 16, 2021 - Java
-
Updated
Jun 7, 2021 - Java
-
Updated
Jul 21, 2021
-
Updated
Nov 12, 2019 - Java
-
Updated
Mar 8, 2021 - Scala
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
There seem to be more space between 'Application Metrics' and 'External Calls' compared to the space between 'External Calls' and 'Database Calls' on Macbook Air 13 inch model.
Expected behavior
The tabs should be evenly spac