DataStreamingIT
112 subscribers
1 photo
83 links
Follow DataStreamingIT to stay on top of Data Streaming & Stream Processing! #datastreamingit
Italian: @kafkastreamingit
Facebook: fb.me/DataStreamingIT
Download Telegram
Apache Spark 3.1.1 is here!

The changes are mainly about:
- Core
- Spark SQL
- Structured Streaming
- PySpark
- MLlib
- SparkR
and more.

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

DataStreamingIT in Italian: @kafkastreamingit

#ApacheSpark #SparkStreaming #PySpark #Python #streamprocessing #datastreamingit
Apache Flink 🐿 Stateful Functions aka StateFun 3.0.0 is out!

New features:
- Unified Languages SDKs;
- Cross-Language Type System;
- Dynamic Registration of State and Functions
and more.

For further details: https://flink.apache.org/news/2021/04/15/release-statefun-3.0.0.html.

DataStreamingIT in italiano: @kafkastreamingit

#ApacheFlink #Flink #StatefulFunctions #StateFun #streamprocessing #datastreamingit
Apache Kafka 2.8.0 is finally out!

- KIP-500: Replace ZooKeeper with a self-managed quorum;
- KIP-700: Add Describe Cluster API;
- KIP-684: Support mutual TLS authentication on SASL_SSL listeners;
- KIP-676: Respect logging hierarchy;
- KIP-673: Emit JSONs with new auto-generated schema;
- KIP-612: Limit broker connection creation rate;
- KIP-516: Topic identifiers.

Kafka Connect
- KIP-661: Expose task configurations in Connect REST API.

Kafka Streams
- KIP-696: Update Streams FSM to clarify ERROR state meaning;
- KIP-689: Extend StreamJoined to allow more store configs;
- KIP-680: TopologyTestDriver should not require a properties argument;
- KIP-671: Introduce Kafka-Streams-specific uncaught exception handler;
- KIP-663: API to start and shut down Streams threads;
- KIP-659: Improve TimeWindowedDeserializer and TimeWindowedSerde to handle window size;
- KIP-572: Improve timeouts and retries in Kafka Streams.

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

Data Streaming IT in Italian: @kafkastreamingit

#ApacheKafka #Kafka #KafkaStreams #streamprocessing #datastreamingit
NATS 2.2 ⚡️ JetStream release is out!

JetStream features:
- At-least-once delivery and exactly once within a window;
- Store data and replay by time or sequence;
- Cleanse specific messages (GDPR);
- Horizontal scalability;
- Persist Streams and replay via Consumers
and more.

For further details: https://nats.io/blog/nats-whats-new-22.

DataStreamingIT in italiano: @kafkastreamingit

#NATS #JetStream #CNCF #golang #streamprocessing #datastreamingit
Apache Druid 0.21.0 🧙‍♂️is here!

New features:
- Leader election based on Kubernetes (without ZooKeeper);
- New grouping aggregator function;
- Old Kafka version support
and much more.

For further details: https://github.com/apache/druid/releases/tag/druid-0.21.0.

DataStreamingIT in italiano: @kafkastreamingit

#ApacheDruid #Druid #realtimeanalytics #databases #datastreamingit
Apache Flink 1.13.0 🐿 is out!

New features:
- Reactive scaling;
- Flame Graphs;
- Machine Learning Library moved to flink-ml;
- Windows via Time-valued functions;
- PyFlink improvements
and much more.

For further details: https://flink.apache.org/news/2021/05/03/release-1.13.0.html.

Data Streaming IT in italiano: @kafkastreamingit

#ApacheFlink #Flink #streamprocessing #SQL #PyFlink #Python #datastreamingit
Kafka Summit APAC 2021 📅 27-28 JUL 📅

Free registration: kafka-summit.org.

Data Streaming IT in italiano: @kafkastreamingit

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