Skip to content

Instantly share code, notes, and snippets.

@KadekM

KadekM/block17.scala Secret

Created March 17, 2021 15:07
Show Gist options
  • Save KadekM/9018e012fd3e3c6f646359cce875e1f8 to your computer and use it in GitHub Desktop.
Save KadekM/9018e012fd3e3c6f646359cce875e1f8 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
block17.scala
def selectPartitionSql(topicPartitions: List[String]) = {
sql"""SELECT topic, "offset" FROM offsets
WHERE topic
IN (${varchar.list(topicPartitions.size)})"""
.query(varchar ~ int8)
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment