O'Reilly logo
  • MARESMA Damien thinks this is interesting:

val eventHubsParameters = Map[String, String]( "eventhubs.namespace" -> inputOptions( Symbol(EventhubsArgumentKeys.EventhubsNamespace)).asInstanceOf[String], "eventhubs.name"

From

Cover of Mastering Azure Analytics, 1st Edition

Note

Deprecated : val connectionString = ConnectionStringBuilder() .setNamespaceName(inputOptions(Symbol(EventhubsArgumentKeys.EventhubsNamespace)).asInstanceOf[String]) .setEventHubName(inputOptions(Symbol(EventhubsArgumentKeys.EventhubsName)).asInstanceOf[String]) .setSasKeyName(inputOptions(Symbol(EventhubsArgumentKeys.PolicyName)).asInstanceOf[String]) .setSasKey(inputOptions(Symbol(EventhubsArgumentKeys.PolicyKey)).asInstanceOf[String]) .build

val eventHubsParameters = EventHubsConf(connectionString)
    .setConsumerGroup(inputOptions(Symbol(EventhubsArgumentKeys.ConsumerGroup)).asInstanceOf[String])
    .setStartingPosition(EventPosition.fromEndOfStream)