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 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 ❀️
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 ❀️
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 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 ❀️
Apache Druid πŸ§™β€β™‚οΈ

Druid Summit 2021 πŸ“… 09-10 NOV πŸ“†

Keynotes:
- Building Modern Analytics Applications with Apache Druid
- Fireside Chat with the Creators of Druid
- Druid Roadmap / Unveiling What's Next for Apache Druid and Imply

Guest Keynote
- Evolution to Data Mesh

πŸŽ™ Jay Kreps,
co-creator of Apache Kafka, Confluent CEO,
author of πŸ“šI πŸ’œ Logs: Event Data, Stream Processing, and Data IntegrationπŸ“–

Free registration: https://druidsummit.org.

Data Streaming IT in italiano: @kafkastreamingit

#ApacheDruid #Druid #ProjectShapeshift #realtimeanalytics #streaminganalytics #ApacheKafka #Kafka #DataMesh #databases #datastreamingit

Feel free to invite your colleagues and friends to join @DataStreamingIT and @kafkastreamingit ❀️
DataStreamingIT
πŸ‡ 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…
πŸ‡ RabbitMQ on Kubernetes Deep Dive
☸️ KubeCon + CloudNatveCon North America 2021 πŸ“Ί: https://youtu.be/GxdyQSUEj5U.


πŸ“… 10 NOV at 10:00 am CET πŸ“† 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 #CNCF #KubeCon #CloudNativeCon #observability #streamprocessing #datastreamingit

Feel free to invite your colleagues and friends to join @DataStreamingIT and @kafkastreamingit ❀️
Apache Kafka 3.1.0 ✨ is here!

New features / KIPs list:

Kafka broker, Producer, Consumer and AdminClient
- KIP-516: Topic identifiers
- KIP-773: Differentiate consistently metric latency measured in millis and nanos
- KIP-768: Extend SASL/OAUTHBEARER with support for OIDC
- KIP-748: Add broker count metrics

Kafka Streams
- KAFKA-13439: The eager rebalance protocol is deprecated
- KIP-783: Add TaskId field to StreamsException
- KIP-775: Custom partitioners in foreign-key joins
- KIP-766: fetch/findSessions queries with open endpoints for SessionStore/WindowStore
- KIP-763: Range queries with open endpoints
- KIP-761: Add total blocked time metric to Streams

MirrorMaker
- KIP-690: Add additional configuration to control MirrorMaker2 internal topics naming convention

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

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 ❀️