Skip to content
#

cosmosdb

Here are 444 public repositories matching this topic...

Streaming reference architecture for ETL with Kafka and Kafka-Connect. You can find more on http://lenses.io on how we provide a unified solution to manage your connectors, most advanced SQL engine for Kafka and Kafka Streams, cluster monitoring and alerting, and more.

  • Updated May 20, 2022
  • Scala
pattisapu01
pattisapu01 commented Apr 21, 2021

In what area(s)?

/area components (kafka pub/sub)

Describe the feature

The current kafka pub/sub component targets just the minimum interfaces to publish and subscribe. We need an enhancement to the kafka component to support "ResetOffets". This means, we need to be able to invoke an API call to the dapr sidecar to "reset" the current offset to a previous value so that messages can b

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
bartelink
bartelink commented Sep 16, 2020

The Streams Scheduler Cpu log line emits a coarse record of all time usage.

It should also record and emit the time the Scheduler spends doing Thread.Sleep.

Probably also applicable to the Parallel Scheduler. Deprecating, see #116

NOTE Sleeps may change a bit when it moves to Channels, see #116

enhancement good first issue up-for-grabs

Improve this page

Add a description, image, and links to the cosmosdb 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 cosmosdb topic, visit your repo's landing page and select "manage topics."

Learn more