`   @source(
    type='kafka',
   bootstrap.servers='xxxx.servicebus.windows.net:9093',
topic.list='mapping-raw',
group.id='$Default',
threading.option='single.thread',
optional.configuration='security.protocol:SASL_SSL,sasl.mechanism:PLAIN,sasl.username:$ConnectionString,sasl.password:Endpoint=sb://xxxx.servicebus.windows.net/;SharedAccessKeyName=tp-stream;SharedAccessKey=123454tqliUPRM5NrnL3sSDJPpCMpmctogQDqvjlehw=;EntityPath=mapping-raw',
 @map(type='json', @attributes(
    Channel='$.Channel',
    Application='$.Application',
    SentDate='$.SentDate',
    Proccess='$.Proccess',
    EntityType='$.EntityType',
    EntityKey='$.EntityKey',
    Entity = '$.Entity'
    )))