IN-PERSON: Reactive Kafka/Windowing in Kafka Streams and Flink SQL/Book signing!
Details
Hello Streamers!
Please join us for an exciting IN-PERSON Apache Kafka® meetup and book signing on Wednesday, May 15th from 5:30pm hosted by our friends at SmartThings, with food and beverage sponsored by KineticEdge and books sponsored by Confluent.
First 40 registered attendees to arrive receive a free copy of Bill Bejeck's new book, Kafka Streams in Action, Second Edition!
Please note: Books are limited.
📍Venue:
Riverplace Building Complex
1 SE Main Street, Minneapolis, MN 55414
Meetup Location Details:
Kafka Meetup will be held in the Garamond Conference Room located inside the Main Hall Building at Riverplace Complex.
*Parking is available on the street or in the Riverplace Parking Ramp on 2nd St SE
***
🗓 Agenda:
- 5:00pm: Doors Open
- 5:15pm-6:00pm: Book signing
- 5:30pm-onward: Food and drink
- 6:00pm-6:45pm: Maintaining Parallelism and Ordering with Reactive Kafka, Mark Eyberg, Staff Engineer, SmartThings
- 6:45pm - 7:30pm: Windowing in Kafka Streams and Flink SQL, Bill Bejeck, Developer Experience Engineer, Confluent
***
💡 Speaker One:
Mark Eyberg, Staff Software Engineer, SmartThings
Title of Talk:
Maintaining Parallelism and Ordering with Reactive Kafka
Abstract:
Apache Kafka provides parallelism and ordering with partitions out-of-the-box through the use of partitions, but once your application reads that data, there is no guarantee the data is processed in order. How can you maintain parallelism and ordering for your data once it’s been consumed? What is Project Reactor, and how can we leverage the Reactive pattern to provide those guarantees? What is back pressure, and how does it apply to Kafka?
In this presentation, Mark will cover:
- what are some of the key applications for using ordering or parallelism in your service
- some techniques to maintain parallelism and ordering using Project Reactor
- what the tradeoffs and caveats are when applying Reactive patterns to your data stream
- how to scale your application to process thousands of records per second without getting them out-of-order
After attending this presentation, developers should be armed with enough knowledge to identify where parallelism and ordering are important, some of the techniques that can be applied to maintain guarantees, and how to avoid some of the pitfalls and caveats that come with implementing ordered parallelism in your service.
Bio:
Mark has been developing software for 17 years. He is currently a Staff Software Engineer at SmartThings. Mark’s application of Reactive Kafka has enabled ordered event processing and delivery for the platform, guarantees that never could be made without leveraging the power of Apache Kafka. Previously, Mark was a Software Consultant at Object Partners (now Improving) working on scalable insurance management systems using Spring Boot and Kafka, an Engineer at Target developing their Authentication portal for target.com, and more.
***
💡 Speaker Two:
Bill Bejeck, Developer Experience Engineer, Confluent
Title of Talk:
Windowing in Kafka Streams and Flink SQL
Abstract:
Stream processing has become the standard way to work with event data with Apache Kafka®, Kafka Streams, and Apache Flink® being the top choices for implementing an event streaming application. In many cases, an individual event isn't the focus of the streaming applications. Instead, it's a series of events within a given period––a discrete window of time––that commands attention. But with the different windowing options available and the time semantics around them, windowing can be tricky to get right.
In this presentation, Bill will cover the following topics for windowing in Kafka Streams and Flink SQL:
- Different types of windows (hopping, tumbling, sliding, etc.) and their application
- The semantics of time advancement, window closing, and emitting results
- Analyzing windowed results
Developers who attend this talk will understand what windowing is in these two streaming technologies.
Bio:
Bill has been a software engineer for over 18 years. Currently, he is working at Confluent as a Staff DevX Engineer. Before Confluent, he worked on various ingest applications as a U.S. Government contractor using distributed software such as Apache Kafka, Spark, and Hadoop. Bill also wrote "Kafka Streams in Action" (https://www.manning.com/books/kafka-streams-in-action-second-edition).
***
DISCLAIMER
BY ATTENDING THIS EVENT IN PERSON, you acknowledge that risk includes possible exposure to and illness from infectious diseases including COVID-19, and accept responsibility for this, if it occurs.
NOTE: We are unable to cater for any attendees under the age of 21.
***
If you would like to speak or host our next event please let us know! community@confluent.io
