Versions Compared

Old Version 4

changes.mady.by.user Erwan Koffi

Saved on

compared with

New Version Current

changes.mady.by.user Erwan Koffi

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

These are kind of the default parameters to use Kafka. The params.kafkaBootstrapServer is the kafka bootstrap servers's urlhostname and port.

Code Block
languagescala
themeRDark
titleKafka parameters
val kafkaParams = Map[String, Object](
  "bootstrap.servers" -> params.kafkaBootstrapServer,
  "key.deserializer" -> classOf[StringDeserializer],
  "value.deserializer" -> classOf[StringDeserializer],
  "group.id" -> "kafka example",
  "auto.offset.reset" -> "earliest",
  "enable.auto.commit" -> (false: java.lang.Boolean)
)

...