daily pastebin goal
53%
SHARE
TWEET

Untitled

a guest Jun 14th, 2018 50 Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
  1. KafkaUtils
  2.   .createDirectStream[String, SomeClass](options...)
  3.   .foreachPartition(
  4.     partition => {
  5.       doSomeWork(partition)
  6.     }
  7.   )
  8.    
  9. Await.result(execute, 2 seconds)
RAW Paste Data
We use cookies for various purposes including analytics. By continuing to use Pastebin, you agree to our use of cookies as described in the Cookies Policy. OK, I Understand
 
Top