What is KEDA? 🤔

Kubernetes Event-Driven Autoscaling: https://keda.sh.

KEDA moves from the CNCF Sandbox to become an incubating project: https://www.cncf.io/blog/2021/08/18/keda-moves-from-the-cncf-sandbox-to-become-an-incubating-project.

Data Streaming IT in italiano: @kafkastreamingit

#KEDA #K8s #Kafka #NATS #RabbitMQ #CNCF #opensource #DevOps #datastreamingit

Feel free to invite your colleagues and friends to join @DataStreamingIT and @kafkastreamingit ❤️

ksqlDB 0.20.0 🚀 is out!

New features:
- DATE and TIME data types
and more.

See: https://twitter.com/ksqldb/status/1428752328841179141?s=21.

Data Streaming IT in italiano: @kafkastreamingit

#ApacheKafka #Kafka #ksqlDB #databases #streamprocessing #datastreamingit

Feel free to invite your colleagues and friends to join @DataStreamingIT and @kafkastreamingit ❤️

📅 ApacheCon Asia 2021 📆 video recordings are now available, including:

- Streaming track 📺: https://www.youtube.com/playlist?list=PLU2OcwpQkYCyFrFJetdGxx1ULjAS3qJ1y;

- Messaging track 📺: https://www.youtube.com/playlist?list=PLU2OcwpQkYCw6MXdsHGmyWgw6LbNnzxdX;

- Big Data track 📺: https://www.youtube.com/playlist?list=PLU2OcwpQkYCwOonGZlbvF33s1PpT0kfTr.

(Please notice that many sessions are in English, but some of them are in Chinese.)

Data Streaming IT in italiano: @kafkastreamingit

#ApacheCon #ApacheFlink #Flink #ApacheSpark #ApacheKafka #Kafka #ApachePulsar #Pulsar #ApacheDruid #Druid #ApachePinot #Pinot #ApacheHudi #Hudi #databases #ASF #opensource #streamprocessing #datastreamingit

Feel free to invite your colleagues and friends to join @DataStreamingIT and @kafkastreamingit ❤️

Apache Flink 🐿 Stateful Functions aka StateFun 3.1.0 ✨ is out!

New features:
- Delayed Message Cancellation;
- New way to specify components;
- GoLang SDK
and much more.

For further details: https://flink.apache.org/news/2021/08/31/release-statefun-3.1.0.html.

DataStreamingIT in italiano: @kafkastreamingit

#ApacheFlink #Flink #StatefulFunctions #StateFun #golang #streamprocessing #datastreamingit

Feel free to invite your colleagues and friends to join @DataStreamingIT and @kafkastreamingit ❤️

Apache Kafka ✨ Uber introduces Consumer Proxy

Enabling Seamless Kafka Async Queuing with Consumer Proxy - Uber Engineering: https://eng.uber.com/kafka-async-queuing-with-consumer-proxy.

Data Streaming IT in italiano: @kafkastreamingit

#ApacheKafka #Kafka #ConsumerProxy #streamprocessing #datastreamingit

Feel free to invite your colleagues and friends to join @DataStreamingIT and @kafkastreamingit ❤️

Apache Spark ⭐️

Introducing the Databricks Community: Online Discussions for Data + AI Practitioners - The Databricks Blog: https://databricks.com/blog/2021/09/08/introducing-the-databricks-community-online-discussions-for-data-ai-practitioners.html.

Databricks Community: https://community.databricks.com.

Data Streaming IT in italiano: @kafkastreamingit

#ApacheSpark #Spark #SparkStreaming #databricks #MLFlow #AI #Python #SQL #datastreamingit

Feel free to invite your colleagues and friends to join @DataStreamingIT and @kafkastreamingit ❤️

Kafka Summit Americas 2021 📅 14-15 SEP 📆 is happening this week!

Free registration: kafka-summit.org.

Data Streaming IT in italiano: @kafkastreamingit

#ApacheKafka #Kafka #KafkaSummit #ksqlDB #KStreams #KafkaStreams #streamprocessing #datastreamingit

Feel free to invite your colleagues and friends to join @DataStreamingIT and @kafkastreamingit ❤️

ApacheCon @ Home 2021 📅 21-23 SEP 📆 is happening this week!

Schedule: https://www.apachecon.com/acah2021/tracks.

Registration: https://hopin.com/events/apachecon-2021-home.

Data Streaming IT in italiano: @kafkastreamingit

#ApacheCon #ASF #ApacheKafka #ApacheFlink #ApacheBeam #ApacheSpark #ApacheNiFi #ApachePulsar #streamprocessing #databases #opensource #datastreamingit

Feel free to invite your colleagues and friends to join @DataStreamingIT and @kafkastreamingit ❤️

Apache Kafka 3.0.0 ✨ is finally here!

New features / KIPs list:

- KIP-750 (Part I): Deprecate support for Java 8 in Kafka;
- KIP-751 (Part I): Deprecate support for Scala 2.12 in Kafka.

Kafka Broker, Producer, Consumer and AdminClient
- KIP-630: Kafka Raft Snapshot;
- KIP-746: Revise KRaft Metadata Records;
- KIP-730: Producer ID generation in KRaft mode;
- KIP-679: Producer will enable the strongest delivery guarantee by default;
- KIP-735: Increase default consumer session timeout;
- KIP-709: Extend OffsetFetch requests to accept multiple group ids;
- KIP-699: Update FindCoordinator to resolve multiple Coordinators at a time;
- KIP-724: Drop support for message formats v0 and v1;
- KIP-707: The future of KafkaFuture;
- KIP-466: Add support for List<T> serialization and deserialization;
- KIP-734: Improve AdminClient.listOffsets to return timestamp and offset for the record with the largest timestamp.

Kafka Connect
- KIP-745: Connect API to restart connector and tasks;
- KIP-738: Removal of Connect's internal converter properties;
- KIP-722: Enable connector client overrides by default;
- KIP-721: Enable connector log contexts in Connect Log4j configuration.

Kafka Streams
- KIP-695: Further improve Kafka Streams timestamp synchronization;
- KIP-715: Expose committed offset in streams;
- KIP-740: Clean up public API in TaskId;
- KKIP-744: Migrate TaskMetadata and ThreadMetadata to an interface with internal implementation;
- KIP-666: Add Instant-based methods to ReadOnlySessionStore;
- KIP-622: Add currentSystemTimeMs and currentStreamTimeMs to ProcessorContext;
- KIP-743: Remove config value 0.10.0-2.4 of Streams built-in metrics version config;
- KIP-741: Change default SerDe to be null;
- KIP-733: Change Kafka Streams default replication factor config;
- KIP-732: Deprecate eos-alpha and replace eos-beta with eos-v2;
- KIP-725: Streamlining configurations for WindowedSerializer and WindowedDeserializer;
- KIP-633: Deprecate 24 hour default for the grace period in Streams;
- KIP-623: Add "internal-topics" option to streams application reset tool.

MirrorMaker
- KIP-720: Deprecate MirrorMaker v1;
- KIP-716: Allow configuring the location of the offset-syncs topic with MirrorMaker2.

For further details, read the Apache blog post: https://blogs.apache.org/kafka/entry/what-s-new-in-apache6.

Data Streaming IT in italiano: @kafkastreamingit

#ApacheKafka #Kafka #KafkaStreams #KStreams #KRaft #streamprocessing #datastreamingit

Feel free to invite your colleagues and friends to join @DataStreamingIT and @kafkastreamingit ❤️

Distributed Systems 💡w/ Apache Kafka, Flink, Pinot @ Uber

Real-Time Exactly-Once Ad Event Processing with Apache Flink, Kafka, and Pinot - Uber Engineering: https://eng.uber.com/real-time-exactly-once-ad-event-processing.

Data Streaming IT in italiano: @kafkastreamingit

#ApacheKafka #Kafka #ApacheFlink #Flink #ApachePinot #Pinot #DistributedSystems #realtimeanalytics #streamprocessing #datastreamingit

Feel free to invite your colleagues and friends to join @DataStreamingIT and @kafkastreamingit ❤️

ksqlDB 0.21.0 🚀 is out!

New features:
⁃ Upgrade to foreign-key table-table joins;
⁃ New ARRAY_ CONCAT function
and more.

See: https://twitter.com/ksqldb/status/1441439447699050498?s=21.

Data Streaming IT in italiano: @kafkastreamingit

#ApacheKafka #Kafka #ksqlDB #databases #streamprocessing #datastreamingit

Feel free to invite your colleagues and friends to join @DataStreamingIT and @kafkastreamingit ❤️

Data Orchestration 📈 w/ Apache Airflow on Kubernetes @ DoorDash

How to Run Apache Airflow on Kubernetes at Scale - DoorDash Engineering: https://doordash.engineering/2021/09/28/how-to-run-apache-airflow-on-kubernetes-at-scale.

Data Streaming IT in italiano: @kafkastreamingit

#ApacheAirflow #Airflow #K8s #ApacheSpark #Spark #Python #opensource #dataorchestration #databases #datastreamingit

Feel free to invite your colleagues and friends to join @DataStreamingIT and @kafkastreamingit ❤️

Apache Flink 1.14.0 🐿 is out!

New features:
⁃ Mix bounded and unbounded streams in an application;
⁃ Mixture of DataStreams API and SQL/Table API support in a program;
⁃ PyFlink improvements
and much more.

For further details, check out the Release Announcement: https://flink.apache.org/news/2021/09/29/release-1.14.0.html.

Data Streaming IT in italiano: @kafkastreamingit

#ApacheFlink #Flink #SQL #PyFlink #Python #streamprocessing #datastreamingit

Feel free to invite your colleagues and friends to join @DataStreamingIT and @kafkastreamingit ❤️

🐇 Interoperability in RabbitMQ Streams - RabbitMQ Blog: https://blog.rabbitmq.com/posts/2021/10/rabbitmq-streams-interoperability.


📅 10 NOV 📆 RabbitMQ 3.9.0 🐰 dallo stream al cloud native

🎙 Gabriele Santomaggio,
co-author of 📚RabbitMQ Cookbook📖,
co-inventor of docs.k3ai.in

Free webminar in Italian: https://tanzu.vmware.com/content/webinars/nov-10-rabbitmq-3-9-0-dallo-stream-al-cloud-native.

Data Streaming IT in italiano: @kafkastreamingit

#RabbitMQ #RabbitMQStreams #AMQP #K8s #streamprocessing #datastreamingit

Feel free to invite your colleagues and friends to join @DataStreamingIT and @kafkastreamingit ❤️

📅 ApacheCon @ Home 2021 📆 video recordings are now available, including:

- Big Data: Streaming track 📺: https://www.youtube.com/playlist?list=PLU2OcwpQkYCwf7Cl6xsCgHuIa8_NWX2JG;

- Big Data track 📺: https://www.youtube.com/playlist?list=PLU2OcwpQkYCzXcumE9UxNirLF1IYLmARj;

- Big Data: SQL / NoSQL 📺: https://www.youtube.com/playlist?list=PLU2OcwpQkYCwu-bpf3K-OIfAjHpf4kr4L.

Data Streaming IT in italiano: @kafkastreamingit

#ApacheCon #ASF #ApacheKafka #ApacheFlink #ApacheSpark #ApacheNiFi #ApachePulsar #ApacheDruid #ApacheHudi #opensource #databases #streamprocessing #datastreamingit

Feel free to invite your colleagues and friends to join @DataStreamingIT and @kafkastreamingit ❤️

Apache Spark 3.2.0 ⭐️ is here!

The changes are mainly about:
- Core and Spark SQL
- Structured Streaming
[including: Upgrade Kafka client to 2.8.0 and EventTime based sessionization (session window)]
- PySpark
- MLlib
- SparkR
- GraphX
and more.

For further details: https://spark.apache.org/releases/spark-release-3-2-0.html.

DataStreamingIT in Italian: @kafkastreamingit

#ApacheSpark #SparkStreaming #PySpark #Python #SQL #streamprocessing #datastreamingit

Feel free to invite your colleagues and friends to join @DataStreamingIT and @kafkastreamingit ❤️

Apache Kafka ✨

New uGroup Kafka consumer monitoring service @ Uber

📝 Introducing uGroup: Uber’s Consumer Management Framework - Uber Engineering: https://eng.uber.com/introducing-ugroup-ubers-consumer-management-framework.

ICYMI

📝 Apache Kafka 3.0 is out! But... by Jason Bell - Digitalis Blog: https://digitalis.io/blog/kafka/apache-kafka-3-0-is-out-but.

Data Streaming IT in italiano: @kafkastreamingit

#ApacheKafka #Kafka #KRaft #observability #streamprocessing #datastreamingit

Feel free to invite your colleagues and friends to join @DataStreamingIT and @kafkastreamingit ❤️

Apache Kafka ✨ Scala

New "ultimate end-to-end tutorial on Kafka Streams" in Scala

Kafka Streams 101 by Riccardo Cardin - Rock the JVM Blog: https://blog.rockthejvm.com/kafka-streams.

Data Streaming IT in italiano: @kafkastreamingit

#ApacheKafka #Kafka #KStreams #Scala #streamprocessing #datastreamingit

Feel free to invite your colleagues and friends to join @DataStreamingIT and @kafkastreamingit ❤️

Apache Flink 🐿

Flink Forward Global 2021 📅 26-27 OCT 📆 is happening this week!

Free registration: https://www.flink-forward.org/global-2021.

Data Streaming IT in italiano: @kafkastreamingit

#ApacheFlink #Flink #FlinkForward #PyFlink #SQL #streamprocessing #datastreamingit

Feel free to invite your colleagues and friends to join @DataStreamingIT and @kafkastreamingit ❤️

Apache Kafka ✨ New Guide to Stream Processing

Kafka Streams Fundamentals - Confluent Blog: https://www.confluent.io/blog/how-kafka-streams-works-guide-to-stream-processing

🖋 Bill Bejeck, Apache Kafka Committer,
author of 📚Kafka Streams in Action📖
and 📚Event Streaming with Kafka Streams and ksqlDB📖 (MEAP)

Data Streaming IT in italiano: @kafkastreamingit

#ApacheKafka #Kafka #KafkaStreams #KStreams #streamprocessing #datastreamingit

Feel free to invite your colleagues and friends to join @DataStreamingIT and @kafkastreamingit ❤️