Skip to content

Instantly share code, notes, and snippets.

View AlessandroStaffolani's full-sized avatar
🏠
Working from home

Alessandro Staffolani AlessandroStaffolani

🏠
Working from home
View GitHub Profile

Keybase proof

I hereby claim:

  • I am ale8193 on github.
  • I am astaffolani (https://keybase.io/astaffolani) on keybase.
  • I have a public key ASD0ByHaradl9SBYDciWZwf59aZxoz6qO86BywGSpXpIIgo

To claim this, I am signing this object:

@AlessandroStaffolani
AlessandroStaffolani / Consumer.scala
Last active February 15, 2019 10:15
Kafka Scala producer consumer test
import java.util.{Collections, Properties}
import org.apache.kafka.clients.consumer.KafkaConsumer
import scala.collection.JavaConverters._
/**
* Consumer object
* @param host String with host or list of hosts separated by comma
* @param topicValue String with the topic value