Types & classes — github.com/Azure/azure-event-hubs-for-kafka

CodeHub MCPcopy Create free account

hub / github.com/Azure/azure-event-hubs-for-kafka / types & classes

Types & classes57 in github.com/Azure/azure-event-hubs-for-kafka

⨍ Functions 249◇ Types & classes 57

ClassAbstractConsumer

tutorials/akka/java/consumer/src/main/java/com/example/app/AkkaTestConsumer.java:16

ClassAbstractProducer

tutorials/akka/java/producer/src/main/java/com/example/app/AkkaTestProducer.java:17

ClassAkkaTestConsumer

tutorials/akka/java/consumer/src/main/java/com/example/app/AkkaTestConsumer.java:47

ClassAkkaTestProducer

tutorials/akka/java/producer/src/main/java/com/example/app/AkkaTestProducer.java:43

ClassAmqpDeserializer

This class implements a deserializer for bytes encoded with the AMQP type system as described by the AMQP 1.0 standard. For more details of the type s

tutorials/interop/AmqpDeserializer.java:42

ClassBrokerStatistic

tutorials/monitoring/librdkafka/dotnet/producer/ProducerMetricsLibrdkafka/ProducerStatistics.cs:39

ClassBrokerStatistic

tutorials/monitoring/librdkafka/dotnet/consumer/ConsumerLaglibrdkafka/ConsumerStatistics.cs:38

TypeAliasClaims

Claims is the main container for our body information

tutorials/oauth/go/producer/producer.go:23

TypeAliasClaims

Claims is the main container for our body information

tutorials/oauth/go/consumer/consumer.go:23

ClassConsumerStatistics

tutorials/monitoring/librdkafka/dotnet/consumer/ConsumerLaglibrdkafka/ConsumerStatistics.cs:6

ClassCustomAuthenticateCallbackHandler

tutorials/oauth/java/appsecret/producer/src/main/java/CustomAuthenticateCallbackHandler.java:31

ClassCustomAuthenticateCallbackHandler

tutorials/oauth/java/appsecret/consumer/src/main/java/CustomAuthenticateCallbackHandler.java:31

ClassCustomAuthenticateCallbackHandler

tutorials/oauth/java/managedidentity/producer/src/main/java/CustomAuthenticateCallbackHandler.java:29

ClassCustomAuthenticateCallbackHandler

tutorials/oauth/java/managedidentity/consumer/src/main/java/CustomAuthenticateCallbackHandler.java:29

ClassCustomAuthenticateCallbackHandler

tutorials/oauth/mirror-maker/src/main/java/CustomAuthenticateCallbackHandler.java:32

tutorials/akka/java/consumer/src/main/java/com/example/app/AkkaTestConsumer.java:26

ClassDescribedType

An AMQP described type consists of a descriptor (an AMQP symbol) and a value. This class packs the two together for convenience when returning.

tutorials/interop/AmqpDeserializer.java:57

ClassDeserTests

tutorials/interop/DeserTests.java:16

ClassFlinkTestConsumer

tutorials/flink/consumer/src/main/java/com/example/app/FlinkTestConsumer.java:11

ClassFlinkTestProducer

tutorials/flink/producer/src/main/java/com/example/app/FlinkTestProducer.java:16

ClassOAuthBearerTokenImp

tutorials/oauth/java/appsecret/producer/src/main/java/OAuthBearerTokenImp.java:8

ClassOAuthBearerTokenImp

tutorials/oauth/java/appsecret/consumer/src/main/java/OAuthBearerTokenImp.java:8

ClassOAuthBearerTokenImp

tutorials/oauth/java/managedidentity/producer/src/main/java/OAuthBearerTokenImp.java:8

ClassOAuthBearerTokenImp

tutorials/oauth/java/managedidentity/consumer/src/main/java/OAuthBearerTokenImp.java:8

ClassOAuthBearerTokenImp

tutorials/oauth/mirror-maker/src/main/java/OAuthBearerTokenImp.java:9

ClassPartitionStatistic

tutorials/monitoring/librdkafka/dotnet/producer/ProducerMetricsLibrdkafka/ProducerStatistics.cs:33

ClassPartitionStatistic

tutorials/monitoring/librdkafka/dotnet/consumer/ConsumerLaglibrdkafka/ConsumerStatistics.cs:32

ClassProducerStatistics

tutorials/monitoring/librdkafka/dotnet/producer/ProducerMetricsLibrdkafka/ProducerStatistics.cs:6

tutorials/monitoring/librdkafka/dotnet/producer/ProducerMetricsLibrdkafka/Program.cs:14

tutorials/monitoring/librdkafka/dotnet/consumer/ConsumerLaglibrdkafka/Program.cs:14

tutorials/interop/AmqpDeserializer.java:43

ClassTestConsumer

tutorials/oauth/java/appsecret/consumer/src/main/java/TestConsumer.java:6

ClassTestConsumer

tutorials/oauth/java/managedidentity/consumer/src/main/java/TestConsumer.java:6

ClassTestConsumer

tutorials/compaction/consumer/src/main/java/TestConsumer.java:6

ClassTestConsumer

quickstart/java/consumer/src/main/java/TestConsumer.java:6

ClassTestConsumerThread

tutorials/oauth/java/appsecret/consumer/src/main/java/TestConsumerThread.java:19

ClassTestConsumerThread

tutorials/oauth/java/managedidentity/consumer/src/main/java/TestConsumerThread.java:12

ClassTestConsumerThread

tutorials/compaction/consumer/src/main/java/TestConsumerThread.java:13

ClassTestConsumerThread

quickstart/java/consumer/src/main/java/TestConsumerThread.java:12

ClassTestDataReporter

tutorials/oauth/java/appsecret/producer/src/main/java/TestDataReporter.java:8

ClassTestDataReporter

tutorials/oauth/java/managedidentity/producer/src/main/java/TestDataReporter.java:9

ClassTestDataReporter

tutorials/compaction/producer/src/main/java/TestDataReporter.java:12

ClassTestDataReporter

quickstart/java/producer/src/main/java/TestDataReporter.java:9

ClassTestProducer

tutorials/oauth/java/appsecret/producer/src/main/java/TestProducer.java:14

ClassTestProducer

tutorials/oauth/java/managedidentity/producer/src/main/java/TestProducer.java:14

ClassTestProducer

tutorials/compaction/producer/src/main/java/TestProducer.java:14

ClassTestProducer

quickstart/java/producer/src/main/java/TestProducer.java:14

StructTokenProvider

TokenProvider is a simple struct that implements sarama.AccessTokenProvider. It encapsulates an oauth2.TokenSource which is leveraged for AccessToken

tutorials/oauth/go-sarama/producer/token-provider.go:14

StructTokenProvider

TokenProvider is a simple struct that implements sarama.AccessTokenProvider. It encapsulates an oauth2.TokenSource which is leveraged for AccessToken

tutorials/oauth/go-sarama/consumer/token-provider.go:14

ClassTopicStatistic

tutorials/monitoring/librdkafka/dotnet/producer/ProducerMetricsLibrdkafka/ProducerStatistics.cs:22

ClassTopicStatistic

tutorials/monitoring/librdkafka/dotnet/consumer/ConsumerLaglibrdkafka/ConsumerStatistics.cs:21

ClassWindowStats

tutorials/monitoring/librdkafka/dotnet/consumer/ConsumerLaglibrdkafka/ConsumerStatistics.cs:44

tutorials/monitoring/librdkafka/dotnet/producer/ProducerMetricsLibrdkafka/Worker.cs:7

tutorials/monitoring/librdkafka/dotnet/consumer/ConsumerLaglibrdkafka/Worker.cs:7

quickstart/dotnet/EventHubsForKafkaSample/Worker.cs:12

StructmessageHandler

tutorials/oauth/go-sarama/consumer/consumer.go:63

StructmessageHandler

quickstart/go-sarama-client/consumer/sarama-consumer.go:69