-
Startup fails when there's no onupdate URL.
-
### Questions
I write a Kafka consumer to consume JSON messages, so I use JsonObjectDeserializer, my configuration is:
```kotlin
val kafkaConfig: Map = mapOf(
"bootstrap.se…
cyhii updated
1 month ago
-
**Describe the bug**
For data in stream with nested map attributes (ie. map of maps) and its value format is JSON_SR, select query will fail with serialization exception. Note that inserts still work…
-
**Describe the bug**
We're experiencing a bug where some of the queries we have deployed (all stateless, all converting json to avro) are experiencing really slow consuming and fail to be terminated …
-
KSQL can flatten ARRAY types only when the size of the array is a known as described in: https://www.confluent.io/blog/data-wrangling-apache-kafka-ksql
Otherwise, when the ARRAY type is of unknown …
-
### Describe the bug
The Dev UI for Kafka Streams shows no / an empty topology when the source topic uses a `Pattern` instead of static names.
```java
package org.acme.consumer;
import org.apa…
-
Description
===========
Start from version 0.10.0.X, Kafka itself supports the Streams APIs, however, seems except the Java version clients support this feature, the .net client still does not suppo…
-
1. Run kafka using docker compose:
```
curl --silent --output docker-compose.yml \
https://raw.githubusercontent.com/confluentinc/cp-all-in-one/7.3.3-post/cp-all-in-one/docker-compose.yml
```…
-
Sometime, after you have all your queries running in interactive mode, you want to modify the default configuration of the existing streams. For example to skip records with invalid timestamp by setti…
-
Hi
I have below setup
Event Streams(Apache kafka platform)
Apicurio schema registry
Java spring custom app that produce avro serialized events using Apicurio SerDes library
Aiven S3…