MCPcopy Create free account

hub / github.com/Kafka-In-Action-Book/Kafka-In-Action-Source-Code / functions

Functions143 in github.com/Kafka-In-Action-Book/Kafka-In-Action-Source-Code

⨍ Functions 143◇ Types & classes 45
Methodmain
(String[] args)
KafkaInAction_Chapter3/src/main/java/org/kafkainaction/producer/HelloWorldProducer.java:19
Methodmain
(String[] args)
KafkaInAction_Chapter3/src/main/java/org/kafkainaction/consumer/HelloWorldConsumer.java:20
MethodonAcknowledgement
(RecordMetadata metadata, Exception exception)
KafkaInAction_Chapter9/src/main/java/org/kafkainaction/producer/AlertProducerMetricsInterceptor.java:26
MethodonCommit
(final Map<TopicPartition, OffsetAndMetadata> map)
KafkaInAction_Chapter9/src/main/java/org/kafkainaction/consumer/AlertConsumerMetricsInterceptor.java:38
MethodonComplete
(Map<TopicPartition, OffsetAndMetadata> map, Exception e)
KafkaInAction_Chapter4/src/main/java/org/kafkainaction/consumer/AlertConsumer.java:69
MethodonCompletion
(RecordMetadata metadata, Exception exception)
KafkaInAction_Chapter9/src/main/java/org/kafkainaction/callback/AlertCallback.java:11
MethodonCompletion
(RecordMetadata metadata, Exception exception)
KafkaInAction_Chapter4/src/main/java/org/kafkainaction/callback/AlertCallback.java:12
MethodonConsume
(ConsumerRecords<Alert, String> records)
KafkaInAction_Chapter9/src/main/java/org/kafkainaction/consumer/AlertConsumerMetricsInterceptor.java:21
MethodonSend
(ProducerRecord<Alert, String> record)
KafkaInAction_Chapter9/src/main/java/org/kafkainaction/producer/AlertProducerMetricsInterceptor.java:18
Functionresult
(err, message)
KafkaInAction_AppendixB/pythonexamples/pythonproducer.py:5
Methodrun
()
KafkaInAction_Chapter12/src/main/java/org/kafkainaction/kstreams2/TransactionProcessor.java:98
Methodrun
()
KafkaInAction_Chapter5/src/main/java/org/kafkainaction/consumer/KinactionStopConsumer.java:25
Methodserialize
(String topic, Alert key)
KafkaInAction_Chapter9/src/main/java/org/kafkainaction/serde/AlertKeySerde.java:13
Methodserialize
(String topic, Alert key)
KafkaInAction_Chapter7/src/main/java/org/kafkainaction/serde/AlertKeySerde.java:13
Methodserialize
(String topic, Alert key)
KafkaInAction_Chapter5/src/main/java/org/kafkainaction/serde/AlertKeySerde.java:13
Methodserialize
(String topic, Alert key)
KafkaInAction_Chapter4/src/main/java/org/kafkainaction/serde/AlertKeySerde.java:13
MethodsetStageId
(String stageId)
KafkaInAction_Chapter9/src/main/java/org/kafkainaction/model/Alert.java:29
MethodsetStageId
(String stageId)
KafkaInAction_Chapter7/src/main/java/org/kafkainaction/model/Alert.java:28
MethodsetStageId
(String stageId)
KafkaInAction_Chapter5/src/main/java/org/kafkainaction/model/Alert.java:28
MethodsetStageId
(String stageId)
KafkaInAction_Chapter4/src/main/java/org/kafkainaction/model/Alert.java:28
MethodsetUp
()
KafkaInAction_Chapter12/src/test/java/org/kafkainaction/kstreams2/TransactionProcessorTest.java:56
Methodsetup
()
KafkaInAction_Chapter12/src/test/java/org/kafkainaction/kstreams2/TransactionTransformerExtendedTest.java:44
Methodsetup
()
KafkaInAction_Chapter12/src/test/java/org/kafkainaction/kstreams2/TransactionTransformerTest.java:41
MethodshouldBeInsufficientFunds
()
KafkaInAction_Chapter12/src/test/java/org/kafkainaction/kstreams2/TransactionProcessorTest.java:127
MethodshouldCloseWithoutErrors
()
KafkaInAction_Chapter12/src/test/java/org/kafkainaction/kstreams2/TransactionTransformerExtendedTest.java:109
MethodshouldCloseWithoutErrors
()
KafkaInAction_Chapter12/src/test/java/org/kafkainaction/kstreams2/TransactionTransformerTest.java:86
MethodshouldCreateSuccessfulTransaction
()
KafkaInAction_Chapter12/src/test/java/org/kafkainaction/kstreams2/TransactionProcessorTest.java:100
MethodshouldInitializeTransformer
()
KafkaInAction_Chapter12/src/test/java/org/kafkainaction/kstreams2/TransactionTransformerTest.java:67
MethodshouldProcessDeposit
()
KafkaInAction_Chapter12/src/test/java/org/kafkainaction/kstreams2/TransactionTransformerExtendedTest.java:78
MethodshouldProcessTransaction
()
KafkaInAction_Chapter12/src/test/java/org/kafkainaction/kstreams2/TransactionTransformerTest.java:73
MethodshouldProcessWithdrawal
()
KafkaInAction_Chapter12/src/test/java/org/kafkainaction/kstreams2/TransactionTransformerExtendedTest.java:91
MethodshouldUseDefaultConstructor
()
KafkaInAction_Chapter12/src/test/java/org/kafkainaction/kstreams2/TransactionTransformerExtendedTest.java:72
Methodshutdown
()
KafkaInAction_Chapter2/src/main/java/org/kafkainaction/consumer/HelloWorldConsumer.java:50
Methodshutdown
()
KafkaInAction_Chapter5/src/main/java/org/kafkainaction/consumer/KinactionStopConsumer.java:43
Methodshutdown
()
KafkaInAction_Chapter5/src/main/java/org/kafkainaction/consumer/WebClickConsumer.java:51
Methodshutdown
()
KafkaInAction_Chapter5/src/main/java/org/kafkainaction/consumer/AuditConsumer.java:59
Methodshutdown
()
KafkaInAction_Chapter5/src/main/java/org/kafkainaction/consumer/ASyncCommit.java:75
Methodshutdown
()
KafkaInAction_Chapter5/src/main/java/org/kafkainaction/consumer/AlertTrendConsumer.java:33
Methodshutdown
()
KafkaInAction_Chapter4/src/main/java/org/kafkainaction/consumer/AlertConsumer.java:40
Methodshutdown
()
KafkaInAction_Chapter3/src/main/java/org/kafkainaction/consumer/HelloWorldConsumer.java:53
Methodsuccess
(String account, TransactionResult result)
KafkaInAction_Chapter12/src/main/java/org/kafkainaction/kstreams2/TransactionProcessor.java:55
MethodtestAlertPartitioner
()
KafkaInAction_Chapter7/src/test/java/org/kafkainaction/producer/AlertLevelPartitionerTest.java:38
MethodtestDriverShouldNotBeNull
()
KafkaInAction_Chapter12/src/test/java/org/kafkainaction/kstreams2/TransactionProcessorTest.java:93
← previous101–143 of 143, ranked by callers