Upcoming Stream Processing Meetup in February!

[Navina Ramesh]

Hi everyone,

We would like to invite you to a Stream Processing Meetup at LinkedIn’s
Sunnyvale campus on Thursday, February 16 at 6pm.

Please RSVP here (if you intend to attend in person):
https://www.meetup.com/Stream-Processing-Meetup-LinkedIn/events/237171557/


We have the following agenda scheduled:

   -

   6PM: Doors open
   -

   6-6:35PM: Networking & Welcome
   -

   6:35-7:10 PM: Asynchronous Processing and Multithreading in Apache
Samza (Xinyu
   Liu, LinkedIn)
   -

   7:15-7:50PM: SSD Benchmarks for Apache Kafka (Mingmin Chen, Uber)
   -

   7:55-8:30 PM: Batching to Streaming Analytics at Optimizely (Vignesh
   Sukumar, Optimizely)

Hope to see you there!

Cheers!
-- 
Navina R.

[GitHub] samza pull request #44: Initial Standalone JobCoordinator and StreamProcesso...

[navina]

GitHub user navina opened a pull request:

https://github.com/apache/samza/pull/44

Initial Standalone JobCoordinator and StreamProcessor API

This patch contains changes associated with the Standalone StreamProcessor, 
where there is no coordination. This will work for load-balanced consumers like 
new Kafka consumer and statically partitioned cases. 

Additionally, we have introduced TaskFactory for StreamTask and 
AsyncStreamTask. 

You can merge this pull request into a Git repository by running:

$ git pull https://github.com/navina/samza Noop-JC

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/samza/pull/44.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #44


commit 76b5167e856984d627a73f020d4ca1c7e9ae8750
Author: Boris Shkolnik 
Date:   2017-01-23T21:16:49Z

added new line at then end

commit 47bf91f8676e26c0de531019e21b6660d744e13f
Author: Boris Shkolnik 
Date:   2017-01-06T20:22:16Z

SAMZA-1076; getKafkaChangelogEnabledStores() should use 
StorageConfig.getChangelo…

getKafkaChangelogEnabledStores() should use 
StorageConfig.getChangelogStream to get changelog system.stream

Author: Boris Shkolnik 

Reviewers: xiliu 

Closes #39 from sborya/KafkConfigForChangelogStream

commit 0dda667b536b14ab12339fc7780db8a7a28bded4
Author: Xinyu Liu 
Date:   2017-01-11T18:42:26Z

SAMZA-1078: Add my gpg key to KEYS

Author: Xinyu Liu 

Closes #41 from xinyuiscool/KEYS

commit 0fc1b4d176c5c62012e32c745d46dc8315a96e3b
Author: navina 
Date:   2017-01-24T19:04:20Z

Adding StreamProcessor and JobCoordinator API along with TaskFactories

commit 70aa08d66d1a1555da69f2607c965d1bc5be0289
Author: navina 
Date:   2017-01-24T19:45:30Z

Removing SimpleGroupByContainer and SimpleGroupByContainerFactory




---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---