kafka-tutorials
kafka-tutorials copied to clipboard
Tutorials and Recipes for Apache Kafka
Bumps [kafka-protobuf-serializer](https://github.com/confluentinc/schema-registry) from 7.1.0 to 7.2.2. Commits e7f0a3e Set Confluent to 7.2.2, Kafka to 7.2.2. 981f857 Adding timer in onJoinPrepare (#2381) c6c05c7 Merge branch '7.1.x' into 7.2.x 9d0af34 Merge branch...
Bumps com.google.protobuf from 0.8.18 to 0.9.1. [](https://docs.github.com/en/github/managing-security-vulnerabilities/about-dependabot-security-updates#about-compatibility-scores) Dependabot will resolve any conflicts with this PR as long as you don't alter it yourself. You can also trigger a...
Bumps [kafka](https://github.com/testcontainers/testcontainers-java) from 1.17.3 to 1.17.5. Release notes Sourced from kafka's releases. 1.17.5 What's Changed Warning Version 1.17.4 was released upgrading slf4j-api to version 2.x. This dependency has been reverted...
Bumps [scala-library](https://github.com/scala/scala) from 2.13.9 to 2.13.10. Commits 4905801 Merge pull request #10182 from som-snytt/issue/7481-nospec-array 69bff24 Test for old crasher cd52542 Merge pull request #10175 from liang3zy22/bug12509 d23620a Avoid parsing code...
- need comma after mq.password in connector: https://developer.confluent.io/tutorials/mainframe-offload/confluent.html - connector config formatting (colon to =): https://github.com/confluentinc/frontend-vault/blob/master/packages/cloud/src/constants/checklist-configs-v2/ksql-recipes/online-dating.js#L62-L67 - comma after kafka.topic: https://developer.confluent.io/tutorials/messaging-modernization/confluent.html - topic name should match case, i.e. lowercase TOPIC-OPERATIONS-AUDIT-LOG:...
Use case: aggregate DLQ topics w/ ksqlDB and send downstream (e.g., to BigQuery) Recipe would, e.g.: 1. create 2 connectors w/ DLQ topics, simulate the DLQ topics via `INSERT` 2....
At https://developer.confluent.io/tutorials/credit-card-activity/confluent.html auto.offset.reset = Latest which is the default, the query will be always loading > 15m  I tried to execute below: /* SET...
ksqlDB 0.17 introduced the ability to use simple in-line functions vs. having to provide a UDF https://www.confluent.io/blog/announcing-ksqldb-0-17-0-new-features-and-updates/#lambda-functions
The 0.17 release provides a new migration tool - https://www.confluent.io/blog/announcing-ksqldb-0-17-0-new-features-and-updates/#version-control
[KIP-464](https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=113708722) introduced the ability for the `Admin API` to create topics using broker default replication factor. Once [KIP-733](https://cwiki.apache.org/confluence/display/KAFKA/KIP-733%3A+change+Kafka+Streams+default+replication+factor+config) gets released with AK version 3.0 we should update all Kafka Streams...