When sinking unix timestamps from Apache Kafka to OpenSearch/ElasticSearch using the dedicated connector, they are not recognized by default as timestamp in the target tech.

Continue Reading

You have an Apache Kafka topic that you want to consume via REST APIs (think curl or just a web browser), how to do it? The reply is Karapace an Open Source (Apache 2.0) tool providing Schema Registry and REST proxy functionality. Let’s check out how to quickly run it on Docker. Step 1: the Apache Kafka® Cluster You need an Apache Kafka cluster up & running, if you have one already you can skip to the next section.

Continue Reading

Useful Links Aiven Signup Code examples to run with Aiven for Apache Flink Flink JDBC SQL Connector Flink SQL CDC Connecto for PostgreSQL

Talk Details

You can tabulate a JSON document (retrieve it as a row) in MySQL with the JSON_TABLE function.

Continue Reading

You can remove a field from JSON document in MySQL with the JSON_REMOVE function.

Continue Reading

You can insert a field in a JSON document in MySQL with the JSON_INSERT function.

Continue Reading

You can edit a JSON document in MySQL with:

• The JSON_SET function that will replace values for JSON paths that exists and add values for the ones that don’t exist.
• The JSON_REPLACE function that will replace values for JSON paths that exists and ignore the ones that don’t exist.

Continue Reading

You can merge two JSON documents in MySQL with:

• the JSON_MERGE_PRESERVE function to concatenate the document values
• the JSON_MERGE_PATCH function to keep the latest value for each key

Continue Reading

You can create a JSON document from fields in Mysql® with the JSON_OBJECT function

Continue Reading

To get the type of a JSON item in MySQL you need to use the JSON_TYPE function.

Continue Reading