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
Patterns of Distributed Systems 🎧
ThoughtWorks Technology Podcast,
🎙 Rebecca Parsons and Zhamak Dehghani,
feat. Unmesh Joshi and Martin Fowler:
https://www.thoughtworks.com/podcasts/patterns-distributed-systems.

The episode is a conversation about and intro to

Patterns of Distributed Systems 📝
blog series by Unmesh Joshi:
https://martinfowler.com/articles/patterns-of-distributed-systems.

Data Streaming IT in italiano: @kafkastreamingit

#DistributedSystems #Kafka #databases #k8s #datastreamingit

Feel free to invite your colleagues and friends to join @DataStreamingIT and @kafkastreamingit ❤️
Apache Kafka new Cloud-Native ☁️ blog series by

Gwen Shapira, Apache Kafka PMC,
author of 📚Kafka: The Definitive Guide, Real-Time Data and Stream Processing at Scale📖 (Second Edition now available in Early Release),

Design Considerations for Cloud-Native Data Systems 📝: https://www.confluent.io/blog/design-considerations-for-cloud-native-data-systems.

Data Streaming IT in italiano: @kafkastreamingit

#ApacheKafka #Kafka #CloudNative #CloudComputing #streamprocessing #datastreamingit

Feel free to invite your colleagues and friends to join @DataStreamingIT and @kafkastreamingit ❤️
From FLaNK Stack aka Flink 🐿, NiFi💧 , Kafka

to FLiP Stack aka Flink 🐿, Pulsar and friends

Tim Spann: https://twitter.com/paasdev/status/1420395830696103942?s=21.

Data Streaming IT in italiano: @kafkastreamingit

#ApachePulsar #Pulsar #ApacheFlink #Flink #ApacheNiFi #NiFi #ApacheKafka #Kafka #streamprocessing #BusinessNews #datastreamingit

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

"Open Source distributed real-time Big Data analytics infrastructure"

The Apache Software Foundation Announces Apache® Pinot as a Top-Level Project: https://blogs.apache.org/foundation/entry/the-apache-software-foundation-announces76.

Data Streaming IT in italiano: @kafkastreamingit

#ApachePinot #Pinot #ASF #opensource #realtimeanalytics #databases #datastreamingit

Feel free to invite your colleagues and friends to join @DataStreamingIT and @kafkastreamingit ❤️
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 ❤️
📅 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 ❤️
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 ❤️
💯 @DataStreamingIT Subscribers Appreciation Poll 🎉

Thank you for supporting Data Streaming IT 🙏🏻 💡 Your opinion is important ❤️ I would like to read / learn more about (multiple choice):
Anonymous Poll
59%
Apache Kafka
32%
Apache Flink
9%
Apache Beam
55%
Apache Spark, Spark Streaming
9%
Apache Pulsar
18%
Apache NiFi
0%
NATS
23%
RabbitMQ Streams
36%
All things data streaming!
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 ❤️