MCPcopy Create free account

hub / github.com/Azure/azure-event-hubs-for-kafka / functions

Functions249 in github.com/Azure/azure-event-hubs-for-kafka

⨍ Functions 249◇ Types & classes 57
↓ 1 callersMethodrun
()
tutorials/oauth/java/appsecret/producer/src/main/java/TestDataReporter.java:20
↓ 1 callersMethodterminateWhenDone
(CompletionStage<Done> result)
tutorials/akka/java/producer/src/main/java/com/example/app/AkkaTestProducer.java:29
↓ 1 callersMethodupdate
(String data)
tutorials/akka/java/consumer/src/main/java/com/example/app/AkkaTestConsumer.java:39
↓ 1 callersMethodvalue
()
tutorials/oauth/java/appsecret/consumer/src/main/java/OAuthBearerTokenImp.java:18
↓ 1 callersMethodvalue
()
tutorials/oauth/java/managedidentity/consumer/src/main/java/OAuthBearerTokenImp.java:18
MethodBadInputBufferTest
()
tutorials/interop/DeserTests.java:20
MethodCleanup
(s sarama.ConsumerGroupSession)
tutorials/oauth/go-sarama/consumer/consumer.go:70
MethodCleanup
(s sarama.ConsumerGroupSession)
quickstart/go-sarama-client/consumer/sarama-consumer.go:76
MethodConsumeClaim
(s sarama.ConsumerGroupSession, c sarama.ConsumerGroupClaim)
tutorials/oauth/go-sarama/consumer/consumer.go:74
MethodConsumeClaim
(s sarama.ConsumerGroupSession, c sarama.ConsumerGroupClaim)
quickstart/go-sarama-client/consumer/sarama-consumer.go:80
MethodConsumerStatistics
()
tutorials/monitoring/librdkafka/dotnet/consumer/ConsumerLaglibrdkafka/ConsumerStatistics.cs:14
MethodCreateHostBuilder
(string[] args)
tutorials/monitoring/librdkafka/dotnet/producer/ProducerMetricsLibrdkafka/Program.cs:104
MethodCreateHostBuilder
(string[] args)
tutorials/monitoring/librdkafka/dotnet/consumer/ConsumerLaglibrdkafka/Program.cs:103
MethodDescribedType
(final String d, final Object v)
tutorials/interop/AmqpDeserializer.java:79
MethodExecuteAsync
(CancellationToken stoppingToken)
tutorials/monitoring/librdkafka/dotnet/producer/ProducerMetricsLibrdkafka/Worker.cs:9
MethodExecuteAsync
(CancellationToken stoppingToken)
tutorials/monitoring/librdkafka/dotnet/consumer/ConsumerLaglibrdkafka/Worker.cs:9
MethodInvalidTypesTest
()
tutorials/interop/DeserTests.java:203
MethodMain
(string[] args)
tutorials/monitoring/librdkafka/dotnet/producer/ProducerMetricsLibrdkafka/Program.cs:17
MethodMain
(string[] args)
tutorials/monitoring/librdkafka/dotnet/consumer/ConsumerLaglibrdkafka/Program.cs:17
MethodOAuthBearerTokenImp
(final String token, Date expiresOn)
tutorials/oauth/java/appsecret/producer/src/main/java/OAuthBearerTokenImp.java:13
MethodOAuthBearerTokenImp
(final String token, Date expiresOn)
tutorials/oauth/java/appsecret/consumer/src/main/java/OAuthBearerTokenImp.java:13
MethodOAuthBearerTokenImp
(final String token, Date expiresOn)
tutorials/oauth/java/managedidentity/producer/src/main/java/OAuthBearerTokenImp.java:13
MethodOAuthBearerTokenImp
(final String token, Date expiresOn)
tutorials/oauth/java/managedidentity/consumer/src/main/java/OAuthBearerTokenImp.java:13
MethodOAuthBearerTokenImp
(final String token, Date expiresOn)
tutorials/oauth/mirror-maker/src/main/java/OAuthBearerTokenImp.java:14
MethodProducerStatistics
()
tutorials/monitoring/librdkafka/dotnet/producer/ProducerMetricsLibrdkafka/ProducerStatistics.cs:15
MethodResult
(final Object r, final int c)
tutorials/interop/AmqpDeserializer.java:47
MethodSetup
(s sarama.ConsumerGroupSession)
tutorials/oauth/go-sarama/consumer/consumer.go:65
MethodSetup
(s sarama.ConsumerGroupSession)
quickstart/go-sarama-client/consumer/sarama-consumer.go:71
MethodTestConsumerThread
(final String TOPIC)
tutorials/oauth/java/appsecret/consumer/src/main/java/TestConsumerThread.java:26
MethodTestConsumerThread
(final String TOPIC)
tutorials/oauth/java/managedidentity/consumer/src/main/java/TestConsumerThread.java:19
MethodTestConsumerThread
(final String TOPIC)
tutorials/compaction/consumer/src/main/java/TestConsumerThread.java:20
MethodTestConsumerThread
(final String TOPIC)
quickstart/java/consumer/src/main/java/TestConsumerThread.java:19
MethodTestDataReporter
(final Producer<Long, String> producer, String TOPIC)
tutorials/oauth/java/appsecret/producer/src/main/java/TestDataReporter.java:15
MethodTestDataReporter
(final Producer<Long, String> producer, String TOPIC)
tutorials/oauth/java/managedidentity/producer/src/main/java/TestDataReporter.java:16
MethodTestDataReporter
(final Producer<String, String> producer, String TOPIC)
tutorials/compaction/producer/src/main/java/TestDataReporter.java:22
MethodTestDataReporter
(final Producer<Long, String> producer, String TOPIC)
quickstart/java/producer/src/main/java/TestDataReporter.java:16
MethodToken
Token returns a new *sarama.AccessToken or an error as appropriate.
tutorials/oauth/go-sarama/producer/token-provider.go:36
MethodToken
Token returns a new *sarama.AccessToken or an error as appropriate.
tutorials/oauth/go-sarama/consumer/token-provider.go:36
MethodTopicStatistic
()
tutorials/monitoring/librdkafka/dotnet/producer/ProducerMetricsLibrdkafka/ProducerStatistics.cs:27
MethodTopicStatistic
()
tutorials/monitoring/librdkafka/dotnet/consumer/ConsumerLaglibrdkafka/ConsumerStatistics.cs:26
MethodType00DescribedTest
()
tutorials/interop/DeserTests.java:266
MethodType40NullTest
()
tutorials/interop/DeserTests.java:346
MethodType4142BooleanTest
()
tutorials/interop/DeserTests.java:354
MethodType4344ZeroTest
()
tutorials/interop/DeserTests.java:389
MethodType45EmptyListTest
()
tutorials/interop/DeserTests.java:407
MethodType505253U8Test
()
tutorials/interop/DeserTests.java:455
MethodType515455S8Test
()
tutorials/interop/DeserTests.java:654
MethodType60U16Test
()
tutorials/interop/DeserTests.java:474
MethodType61S16Test
()
tutorials/interop/DeserTests.java:669
MethodType70U32Test
()
tutorials/interop/DeserTests.java:513
MethodType71S32Test
()
tutorials/interop/DeserTests.java:715
MethodType72F32Test
()
tutorials/interop/DeserTests.java:838
MethodType73UTF32CharTest
()
tutorials/interop/DeserTests.java:989
MethodType74Decimal32Test
()
tutorials/interop/DeserTests.java:933
MethodType80U64Test
()
tutorials/interop/DeserTests.java:558
MethodType81S64Test
()
tutorials/interop/DeserTests.java:760
MethodType82F64Test
()
tutorials/interop/DeserTests.java:900
MethodType83TimestampTest
()
tutorials/interop/DeserTests.java:1027
MethodType84Decimal64Test
()
tutorials/interop/DeserTests.java:945
MethodType94Decimal128Test
()
tutorials/interop/DeserTests.java:957
MethodType98UUIDTest
()
tutorials/interop/DeserTests.java:1068
MethodTypeA0ShortBinaryTest
()
tutorials/interop/DeserTests.java:1112
MethodTypeA1ShortStringTest
()
tutorials/interop/DeserTests.java:1324
MethodTypeA3ShortSymbolTest
()
tutorials/interop/DeserTests.java:1334
MethodTypeB0LongBinaryTest
()
tutorials/interop/DeserTests.java:1142
MethodTypeB1LongStringTest
()
tutorials/interop/DeserTests.java:1329
MethodTypeB3LongSymbolTest
()
tutorials/interop/DeserTests.java:1339
MethodTypeC0ShortListTest
()
tutorials/interop/DeserTests.java:1344
MethodTypeC1ShortMapTest
()
tutorials/interop/DeserTests.java:1356
MethodTypeD0LongListTest
()
tutorials/interop/DeserTests.java:1368
MethodTypeD1LongMapTest
()
tutorials/interop/DeserTests.java:1380
MethodTypeE0ShortArrayTest
()
tutorials/interop/DeserTests.java:1392
MethodTypeF0ShortArrayTest
()
tutorials/interop/DeserTests.java:1404
Methodclose
()
tutorials/oauth/java/appsecret/producer/src/main/java/CustomAuthenticateCallbackHandler.java:91
Methodclose
()
tutorials/oauth/java/managedidentity/producer/src/main/java/CustomAuthenticateCallbackHandler.java:71
Methodconfigure
(Map<String, ?> configs, String mechanism, List<AppConfigurationEntry> jaasConfigEntries)
tutorials/oauth/java/appsecret/producer/src/main/java/CustomAuthenticateCallbackHandler.java:41
Methodconfigure
(Map<String, ?> configs, String mechanism, List<AppConfigurationEntry> jaasConfigEntries)
tutorials/oauth/java/appsecret/consumer/src/main/java/CustomAuthenticateCallbackHandler.java:41
Methodconfigure
(Map<String, ?> configs, String mechanism, List<AppConfigurationEntry> jaasConfigEntries)
tutorials/oauth/java/managedidentity/producer/src/main/java/CustomAuthenticateCallbackHandler.java:38
Methodconfigure
(Map<String, ?> configs, String mechanism, List<AppConfigurationEntry> jaasConfigEntries)
tutorials/oauth/java/managedidentity/consumer/src/main/java/CustomAuthenticateCallbackHandler.java:38
Methodconfigure
(Map<String, ?> configs, String mechanism, List<AppConfigurationEntry> jaasConfigEntries)
tutorials/oauth/mirror-maker/src/main/java/CustomAuthenticateCallbackHandler.java:42
Methodconfigure
Required by the Deserializer<> interface, but this deserializer has no configurable values.
tutorials/interop/AmqpDeserializer.java:88
Functiondelivery_callback
(err, msg)
tutorials/oauth/python/producer.py:57
Functiondelivery_callback
(err, msg)
quickstart/python/producer.py:36
Methodhandle
(Callback[] callbacks)
tutorials/oauth/java/appsecret/producer/src/main/java/CustomAuthenticateCallbackHandler.java:56
Methodhandle
(Callback[] callbacks)
tutorials/oauth/java/appsecret/consumer/src/main/java/CustomAuthenticateCallbackHandler.java:56
Methodhandle
(Callback[] callbacks)
tutorials/oauth/java/managedidentity/producer/src/main/java/CustomAuthenticateCallbackHandler.java:46
Methodhandle
(Callback[] callbacks)
tutorials/oauth/java/managedidentity/consumer/src/main/java/CustomAuthenticateCallbackHandler.java:46
Methodhandle
(Callback[] callbacks)
tutorials/oauth/mirror-maker/src/main/java/CustomAuthenticateCallbackHandler.java:57
MethodlifetimeMs
()
tutorials/oauth/java/appsecret/producer/src/main/java/OAuthBearerTokenImp.java:28
MethodlifetimeMs
()
tutorials/oauth/java/appsecret/consumer/src/main/java/OAuthBearerTokenImp.java:28
MethodlifetimeMs
()
tutorials/oauth/java/managedidentity/producer/src/main/java/OAuthBearerTokenImp.java:28
MethodlifetimeMs
()
tutorials/oauth/java/managedidentity/consumer/src/main/java/OAuthBearerTokenImp.java:28
MethodlifetimeMs
()
tutorials/oauth/mirror-maker/src/main/java/OAuthBearerTokenImp.java:29
MethodloadOffset
()
tutorials/akka/java/consumer/src/main/java/com/example/app/AkkaTestConsumer.java:35
Functionmain
()
tutorials/oauth/go/producer/producer.go:112
Functionmain
()
tutorials/oauth/go/consumer/consumer.go:115
Functionmain
()
tutorials/oauth/go-sarama/producer/producer.go:14
Functionmain
()
tutorials/oauth/go-sarama/consumer/consumer.go:15
Functionmain
()
quickstart/go/producer/producer.go:16
Functionmain
()
quickstart/go/consumer/consumer.go:16
← previousnext →101–200 of 249, ranked by callers