kafka
Here are 6,970 public repositories matching this topic...
-
Updated
Dec 15, 2021 - Java
-
Updated
Jan 4, 2022 - Java
-
Updated
Jan 24, 2022 - Java
-
Updated
Dec 7, 2021 - Scala
-
Updated
Jan 24, 2022 - Java

-
Updated
Jan 18, 2022 - Python
-
Updated
Jan 24, 2022 - C
Describe the bug
There are a few functions (AS_MAP, ARRAY_SORT and URL_ENCODE_PARAM for example) that don't do null checks on inputs. We should do null checks because these errors are left uncaught and end up crashing queries. An example of one that has been fixed recently is confluentinc/ksql#8400
-
Updated
Jan 21, 2022 - Go
-
Updated
Jan 15, 2022 - Java
-
Updated
Apr 24, 2020 - Jsonnet
Under the hood, Benthos csv input uses the standard encoding/csv packages's csv.Reader struct.
The current implementation of csv input doesn't allow setting the LazyQuotes field.
We have a use case where we need to set the LazyQuotes field in order to make things work correctly.
i'm attempting to write a health check for a service that uses watermill and i'd like to be able to easily determine if the router is still up and running
Router exposes a channel at .Running(), and it's possible to infer if the router is closed with a little indirection:
running := false
go func() {
r := router.Running()
for {
if _, open := <-r; open {
running -
Updated
Aug 3, 2021 - Go
-
Updated
Jan 25, 2022 - Rust
-
Updated
Jan 24, 2022 - Java
-
Updated
Jan 22, 2022 - Java
Version & Environment
Redpanda version: (use rpk version):
v21.11.2 (rev f58e69b)
What went wrong?
Accessing the admin API at hostname:9644/v1 fails. On the browser, the request hangs for several minutes (dev tools shows it as a in-progress, waiting for more bytes), before eventually failing (timing out).
wget shows some kind of read error 6.5K into the response:
~~
-
Updated
Jan 24, 2022 - JavaScript
Improve this page
Add a description, image, and links to the kafka topic page so that developers can more easily learn about it.
Add this topic to your repo
To associate your repository with the kafka topic, visit your repo's landing page and select "manage topics."


