►
From YouTube: Messaging with Azure Event Hubs
Description
Azure Event Hubs Documentation
https://docs.microsoft.com/en-us/azure/event-hubs?WT.mc_id=ondotnet-c9-cxa
In this episode, Serkant Karaca and Shubha Vijayasarathy from the Azure Event Hubs team join us to talk about how and when to use Azure Event Hubs as the messaging component in our .NET applications. They'll discuss use cases, cover topics like partitioning and also show how to use the .NET SDK for Event Hubs.
[01:06] - How is Event Hubs different from the other messaging options?
[03:50] - How does Event Hubs relate to IoT Hub?
[06:14] - Exploring an Event Hubs namespace in the Azure portal
[08:33] - Sending events via the .NET SDK
[17:40] - How do partitions work in Event Hubs?
[23:11] - Receiving events via the .NET SDK
Enable reliable messaging for Big Data applications using Azure Event Hubs
https://docs.microsoft.com/en-us/learn/modules/enable-reliable-messaging-for-big-data-apps-using-event-hubs?WT.mc_id=ondotnet-c9-cxa
Choose between Azure messaging services
https://docs.microsoft.com/en-us/azure/event-grid/compare-messaging-services?WT.mc_id=ondotnet-c9-cxa
Azure IoT Documentation
https://docs.microsoft.com/en-us/azure/iot-hub?WT.mc_id=ondotnet-c9-cxa
Send events to or receive events from Azure Event Hubs using .NET Core
https://docs.microsoft.com/en-us/azure/event-hubs/event-hubs-dotnet-standard-getstarted-send?WT.mc_id=ondotnet-c9-cxa
Microsoft.Azure.EventHubs NuGet package
https://www.nuget.org/packages/Microsoft.Azure.EventHubs/
A
A
B
So
my
name
is
Shu
Babaji
authority,
I'm,
a
senior
program
manager
with
event
hubs
and
even
helps
falls
under
the
messaging
services.
We
do
have
like
ground
for
messaging
services
and
even
helps
provides
you
a
data
streaming
platform
and
yeah
be
pretty
much
here
to
talk
about
various
SDK
and
various
options.
B
B
B
So
you
have
messaging
services
like
service
bus,
which
is
more
like
an
enterprise
message
broker
where
it
says
I'm,
taking
message
from
point
A
to
point
B
securely
asynchronously
reliably,
but
once
I
reach
to
point
B
I
want
some
action
to
be
performed
on
me.
Like
you
know,
it's
a
look
sender,
I'm
sending
but
receiver
do
something.
Yeah.
A
A
B
You're
thinking
of
other
messaging
services,
like
even
Grid,
it's
more
like
notification,
kind
of
a
service
which
says
hey.
You
were
interested
in
this,
so
I'm
pushing
you,
this
notification
saying
you
know
something
happened.
It
could
be
some
kind
of
crud,
that's
happening
among
our
resources.
Now
there
comes
even
hubs
which,
like
I
mentioned,
is
a
data
streaming
platform
when
you're
sending
lot
of
data
a
lot
of
messages
and
as
soon
as
it
reaches
the
event
hubs,
it
says:
hey
the
FII.
B
B
A
B
Difference
between
other
messaging
services
and
even
topsis
once
the
message
is
in
event,
hubs
like
I
said
it's
an
FYI,
because
the
message
is
retain
there
for
a
defined
policy
or
defined
period
of
time,
and
it
does
not
get
deleted
or
the
user
cannot
or
the
consumer
cannot
delete
it.
It
just
expires
over
time.
Okay,.
A
B
Hub
when
you
thinking
of
IOT
hub
it
you're
thinking
of
devices
management
of
devices,
so
it's
nothing
new
that
you
know
every
every
message
that
comes
in
to
IOT
hub
gets
streamed
into
event
hubs,
but
IOT
hub
is
built
on
top
of
event
hub
wherein
you
are
not
just
dreaming
you're,
not
just
going
from.
You
know,
point
A
to
point
B,
but
you
are
trying
to
manage
your
devices
also.
B
So
it's
like
a
different
kind
of
protocol
that
it
uses
a
different
kind
of
management
that
it
uses.
So
it's
a
it's
a
specialized
case
of
even
apps,
I
would
say
not
I
mean
where
you
are
thinking
about
devices
and
devices
alone,
not
just
streaming
gotcha.
So
this
is
like
you
know.
I
I
have
a
series
of
data,
that's
coming
in
where
I'm
trying
to
observe
patterns
and
things
of
the
sort
where
one
message
might
not
be
of
you
know
complete
interest,
but
a
series
of
such
messages
might
be
of
interest.
B
A
B
B
A
Know,
I
also
have
a
situation
where
my
the
storage
of
these
measures
is
somewhat
persistent.
Persistent
from
the
perspective
you
know,
after
I've
acted
upon
correct
the
message
it
doesn't
necessarily
like
disappear.
Yes,
like
something
like,
as
your
event
held
I
might
say:
hey
I've
completed
this
mission.
It's
gone
away.
You
know
we
have
like
this
persistent
store
so.
B
Plans
now
could
look
back.
Yes
exactly
you
can
replay
actual
message.
Yes,
you
can
replay
those
messages
because
you
might
have
what
even
HAP's
offers
is
not
a
single
consumer
at
a
point
on
time
it
can
have
concurrent
consumers.
So
all
these
concurrent
consumers
are
trying
to
consume
from
this
buffer
at
the
same
time,
so
each
one
might
be
replaying
or
even
reading.
For
the
first
time
a
different.
You
know
checkpointing
or
a
different
point
in
time
through
the
buffer
yeah.
A
A
B
C
B
What,
as
soon
as
you
go
and
log
into
your
portal,
you
would
look
for
event,
hubs
to
create
or
to
start
using
event
hubs.
So
once
you
get
into
the
portal-
and
you
start
seeing
you
know
looking
for
event
hubs,
you
were
asked
to
create
a
namespace.
What
a
namespace
gives
you
is
like
endpoint
or
a
or
a
starting
point
where
you
can
start
streaming
or
start
talking
to
even
top
service
and
start
streaming.
B
Your
data,
so
the
name
service
is
your
starting
point
under
the
namespace
comes
the
event
hub
instances
into
which
you're
actually
streaming
the
data.
So
when
senders
are,
producers
are
producing,
it
was
in
to
they
even
have
instances
under
the
name
space
that
you
stream
into
and
consumers
would
be
using
those
event
hubs
to
consume
as
well.
So.
B
A
A
B
A
C
As
we
talked,
you
can
create
shared
access
policies
which
defines
granular
access,
I,
say,
white
fold,
you're
gonna
have
the
route
man
shared
access
key,
which
will
give
you
all
the
manage
tenderness
and
claims.
So
once
you
go
there,
you
can
just
copy
pay
copy
the
connection
string
from
here
and
then
start
running
your
client.
So.
B
A
B
A
C
C
A
C
This
will
give
you
the
connection
string,
which
includes
the
event
up
name
so,
but
using
this
one,
you
basically
call
your
on
top
client
that
create
from
connection
string
API,
which
will
give
you
the
event
up,
client
yeah.
So
then
you
can
start
sending
your
messages.
So
basically
I
think
this
is
the
basic
one
you
can
just
you
know,
craft
an
event,
data
with
some
message
body
and
then
each
time
you
create
an
event
data.
Then
you
call
the
icing:
send
essing
method
got.
A
It
so
two
questions
I
have
really
quickly,
and
this
is
some
snares
that
I've
run
into
as
I
work
with
for
messaging
clients,
so
whenever
I
create
a
messaging
client,
particularly
for
events,
is
that
something
that
I
want
to
keep
around
for
a
long
time
is
that
should
I
have
that,
like
as
a
singleton
inside
of
my
application,
or
is
it
like
really
expensive
for
me
to
create
like
how
do
you?
How
would
I
manage
that,
like
my.
C
Top
client
is
stretch
safe,
so
we
mostly
recommend
our
customers
to
create
the
client
and
then
keep
the
connection
as
long
as
possible.
Got
it
and
because
it'll
save
you
some
overhead
in
terms
of
the
like
TLS
handshake.
Those
kind
of
you
know
like
time
spent
for
creating
connections
and
security.
Those
kind
of
things
got.
A
C
B
A
A
A
B
A
Also,
another
thing
that
that
was
in
your
code
that
I
wanted
to
talk
about
a
little
bit
was
so
I
saw
like
when
you're
looking
at
line
26
all
right.
So
I
noticed
that
your
you
know
your
formatting,
your
your
your
your
text
and
ASCII
right
now,
I
know.
Sometimes
when
it
comes
to
sending
messages
back
and
forth
like
that
texting
courting
is
super
important.
You
know,
I
mean.
B
A
Also
dependent
on
whatever
that
underlying
messaging
infrastructure
happens
to
be
so
I
guess
my
question
is
one:
could
you
tell
me
like
what
is
the?
What
is
the
messaging
protocol
of
our
user
and
then
to
like
what?
What
type
of
format
should
we
have
our
texted
like?
Should
we
kind
of
kind
of
handle,
utf-8
or
unicode
and,
like
those
types
of
things.
A
C
A
C
B
A
C
B
B
A
A
B
C
C
B
It
completely
depends
on
how
much
you
want
to
ingress
with
us,
but
each
throughput
each,
how
many
it
depends
on
how
many
throughputs
you
would
want
to
buy,
or
you
want
to
reserve
we.
It
comes
in
two
different
flavors,
which
is
a
multi-tenant
flavor,
which
gives
you
bandwidth
or
resource
bandwidth,
or
it
comes
in
singleton
and
dedicated
clusters.
Very
where
you
say
you
know:
I
don't
want
to
reserve
any
bandwidth,
but
I
want
to.
You
know,
buy
the
whole
capacity
and
just
max
it
out.
Yeah.
A
C
A
A
A
A
A
C
And
then,
on
the
receiver
side,
the
coating
is
also
very
simple.
You
have
the
connection
string
and
even
type
name.
Then
you
craft
the
connect
string
builder
with
port
of
them
and
then
create
another
client.
On
top
of
that,
and
as
the
next
thing
we
go
and
then
call
get
random
information
as
saying
API
to
discover
how
many
partitions
are
there
available
in
this
particular,
because
it's
it's
up
to
a
developer,
to
either
say
two
partitions
or
two
partitions.
Okay,.
B
So
the
I
explained
that
event
hub
is
a
buffer
and
inside
that
buffer,
architectural
II.
The
way
we
distribute
messages
is
with
some
concept
called
partitions.
Now.
Why
we
have
these
partitions
is
so
that
I
also
mentioned
that,
in
with
event
ups,
you
can
concurrently
consume
all
the
data.
That's
coming
in,
so
to
maximize
the
parallel
consuming
methodology.
You
have
partitions
so
data,
that's
coming
inside
event.
Hubs
gets
distributed
in
these
partitions
and
you
hook
up
the
consumers
to
consume
from
each
of
these
partitions.
A
C
B
B
We
have
three
different
types
of
sender
patterns,
yeah,
which
influence
how
the
data
is
distributed
in
each
of
these
partitions.
So
by
default,
when
you
do
not
mention
what
kind
of
send
a
pattern,
we
round-robin
the
data
where
the
data
just
gets
distributed
on
the
available
partitions
and
then
it's
equally
distributed.
It's.
C
B
Us
you
it's
pretty
transparent,
you
wouldn't
you,
you
would
not
know
you.
You
really
not
know
what
partitions
you're
sending
in
between
and
even
when
you're
consuming.
You
would
not
know
what
partitions
your
sense
you
may
get
from,
but
the
data
this
just
gets
distributed.
Then
we
have
the
partition
key
pattern.
Where-
and
you
say,
okay
I
want
all
my
data
coming
in
to
go
to
Shuba
partition,
yeah.
A
B
B
Then
the
less
recommended
is
the
partition
ID,
where
you're
trying
to
send
to
a
particular
partition.
Id
now
I
should
bring
this
up
saying
the
partition
ID.
If
you
say
one
does
not
mean
it'll
map
to
the
partition
ID,
one
that
we
follow.
It's
completely
different,
it's
a
reference
that
the
client
is
trying
to
send
to.
A
B
Are
kind
of
trying
to
wait
for
that
particular
partition
to
be
available.
These
are
self-healing
distributed
systems
if
a
partition
is
not
available
because
of
a
load
balancing
that's
happening
on
our
end,
it's
only
intermediate,
but
then
there
are
applications
where
which
depend
on
yeah.
No
I
cannot
have
even
a
millisecond
delay.
Yeah.
A
C
B
C
A
C
The
other
one,
the
other
sending
metallurgy,
is
creating
a
partition
sender
so
basically,
on
the
client
itself,
once
your
client,
once
you
create
the
same
client,
you
call
the
create
partition
center
with
the
partner
you
want
to
send
to
it
right.
So
this
part,
this
partition
sender,
has
its
own,
send
as
he
made
it.
So
it's
the
same
thing
as
you
provide
the
event
data
and
then
call
sentencing,
and
then
you
are
now
targeting
the
specific
partition.
The
last
one
is
the
short
one
is
they're,
sending
a
partition
key.
Basically
you
can.
C
What
you
are
doing
here
is
this:
on
the
grant
up,
client,
you
are
sending
the
message
with
attaching
a
partition
key
so
depending
on
the
hashing
algorithm,
so
that
partition
give
a
map
to
a
single
partition.
So
your
message
will
be
landing
on
that,
and
so
it
helps
you
to
just
send
all
relief
messages
with
the
same
partition
key
to
land
on
the
same
partition.
So
it.
A
C
C
A
C
We
took
one
of
you
can
spawn
a
single
task
which
receives
from
a
dedicated
partition
so
basically
in
each
task
only
one
top
client.
This
is
using
the
same
client
and
then
you
create
a
receiver
with
the
full
consumer
group.
So
you
can.
If
you
have
multiple
consumer
groups,
you're
gonna,
you
can
just
specify
your
own
consumer
yeah.
A
C
And
then,
once
you
have
the
receiver,
basically,
you
call
the
receiver
see
method,
and
then
you
specify
how
many
messages
you
are
expecting
at
most.
So
let's
say
this
sample
is
telling
give
me
ten
messages
at
most.
So
whatever
is
available,
it
will
give
you
up
to
ten
messages,
and
let
me
run
this
one.
No.