Functions — github.com/Kafka-In-Action-Book/Kafka-In-Action-Source-Code

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

↓ 8 callersMethodgetSpecificAvroSerde

(final Properties envProps)

KafkaInAction_Chapter12/src/main/java/org/kafkainaction/kstreams2/SchemaSerdes.java:15

↓ 5 callersMethodcreateTopics

(Properties p, String... names)

KafkaInAction_Chapter12/src/main/java/org/kafkainaction/kstreams2/TransactionProcessor.java:114

↓ 5 callersMethodgetFunds

(String account)

KafkaInAction_Chapter12/src/main/java/org/kafkainaction/kstreams2/TransactionTransformer.java:50

↓ 5 callersMethodprocess

(Record<String, Transaction> record)

KafkaInAction_Chapter12/src/main/java/org/kafkainaction/kstreams2/TransactionTransformer.java:64

↓ 4 callersMethodinit

(ProcessorContext<String, TransactionResult> context)

KafkaInAction_Chapter12/src/main/java/org/kafkainaction/kstreams2/TransactionTransformer.java:58

↓ 4 callersMethodpartition

(final String topic, final Object objectKey, final byte[] keyByt

KafkaInAction_Chapter7/src/main/java/org/kafkainaction/partitioner/AlertLevelPartitioner.java:14

↓ 3 callersMethodclose

()

KafkaInAction_Chapter12/src/main/java/org/kafkainaction/kstreams2/TransactionTransformer.java:36

↓ 3 callersMethodpartition

(final String topic, final Object objectKey, final byte[] keyByt

KafkaInAction_Chapter4/src/main/java/org/kafkainaction/partitioner/AlertLevelPartitioner.java:14

↓ 2 callersMethodclose

()

KafkaInAction_Chapter9/src/main/java/org/kafkainaction/serde/AlertKeySerde.java:29

↓ 2 callersMethodgetAlertMessage

()

KafkaInAction_Chapter7/src/main/java/org/kafkainaction/model/Alert.java:36

↓ 2 callersMethodgetAlertMessage

()

KafkaInAction_Chapter4/src/main/java/org/kafkainaction/model/Alert.java:36

↓ 2 callersMethodgetStageId

()

KafkaInAction_Chapter4/src/main/java/org/kafkainaction/model/Alert.java:24

↓ 2 callersMethodtopology

(final StreamsBuilder builder, final SpecificAvroSerde<Transaction> transactionRequ

KafkaInAction_Chapter12/src/main/java/org/kafkainaction/kstreams2/TransactionProcessor.java:125

↓ 2 callersMethodupdateFunds

(String account, BigDecimal amount)

KafkaInAction_Chapter12/src/main/java/org/kafkainaction/kstreams2/TransactionTransformer.java:88

↓ 1 callersMethodclose

()

KafkaInAction_Chapter5/src/main/java/org/kafkainaction/serde/AlertKeySerde.java:30

↓ 1 callersMethodcommitOffset

(long offset, int partition, String topi

KafkaInAction_Chapter5/src/main/java/org/kafkainaction/consumer/ASyncCommit.java:53

↓ 1 callersMethodcommitOffset

(long offset, int part, String topic, KafkaConsumer<Alert, String> consumer)

KafkaInAction_Chapter4/src/main/java/org/kafkainaction/consumer/AlertConsumer.java:60

↓ 1 callersMethodconfigure

(final Map<String, ?> configs, final boolean isKey)

KafkaInAction_Chapter9/src/main/java/org/kafkainaction/serde/AlertKeySerde.java:24

↓ 1 callersMethodconsume

(Properties kaProperties)

KafkaInAction_Chapter2/src/main/java/org/kafkainaction/consumer/HelloWorldConsumer.java:36

↓ 1 callersMethodconsume

(Properties kaProperties)

KafkaInAction_Chapter5/src/main/java/org/kafkainaction/consumer/WebClickConsumer.java:36

↓ 1 callersMethodconsume

(final Properties kaProperties)

KafkaInAction_Chapter5/src/main/java/org/kafkainaction/consumer/AuditConsumer.java:36

↓ 1 callersMethodconsume

(final Properties kaProperties)

KafkaInAction_Chapter5/src/main/java/org/kafkainaction/consumer/ASyncCommit.java:37

↓ 1 callersMethodconsume

(final Properties kaProperties)

KafkaInAction_Chapter5/src/main/java/org/kafkainaction/consumer/AlertTrendConsumer.java:38

↓ 1 callersMethodconsume

(final Properties kaProperties)

KafkaInAction_Chapter4/src/main/java/org/kafkainaction/consumer/AlertConsumer.java:44

↓ 1 callersMethodconsume

(Properties kaProperties)

KafkaInAction_Chapter3/src/main/java/org/kafkainaction/consumer/HelloWorldConsumer.java:38

↓ 1 callersMethodcreateEmptyFunds

(String account)

KafkaInAction_Chapter12/src/main/java/org/kafkainaction/kstreams2/TransactionTransformer.java:40

↓ 1 callersMethodcreateTopic

(String topicName, int partitions)

KafkaInAction_Chapter7/src/test/java/org/kafkainaction/producer/AlertLevelPartitionerTest.java:93

↓ 1 callersMethoddepositFunds

(Transaction transaction)

KafkaInAction_Chapter12/src/main/java/org/kafkainaction/kstreams2/TransactionTransformer.java:46

↓ 1 callersMethoddetermineProperty

(String line, Properties kaProperties)

KafkaInAction_Chapter4/src/main/java/org/kafkainaction/producer/FlumeSinkProducer.java:47

↓ 1 callersMethodfindCriticalPartitionNumber

(Cluster cluster, String topic)

KafkaInAction_Chapter7/src/main/java/org/kafkainaction/partitioner/AlertLevelPartitioner.java:29

↓ 1 callersMethodfindCriticalPartitionNumber

(Cluster cluster, String topic)

KafkaInAction_Chapter4/src/main/java/org/kafkainaction/partitioner/AlertLevelPartitioner.java:29

↓ 1 callersMethodfindRandomPartition

(Cluster cluster, String topic, Object objectKey)

KafkaInAction_Chapter7/src/main/java/org/kafkainaction/partitioner/AlertLevelPartitioner.java:34

↓ 1 callersMethodfindRandomPartition

(Cluster cluster, String topic, Object objectKey)

KafkaInAction_Chapter4/src/main/java/org/kafkainaction/partitioner/AlertLevelPartitioner.java:34

↓ 1 callersMethodgetAlertLevel

()

KafkaInAction_Chapter7/src/main/java/org/kafkainaction/model/Alert.java:32

↓ 1 callersMethodgetAlertLevel

()

KafkaInAction_Chapter4/src/main/java/org/kafkainaction/model/Alert.java:32

↓ 1 callersMethodgetAlertMessage

()

KafkaInAction_Chapter9/src/main/java/org/kafkainaction/model/Alert.java:37

↓ 1 callersMethodgetStageId

()

KafkaInAction_Chapter9/src/main/java/org/kafkainaction/model/Alert.java:25

↓ 1 callersMethodgetStageId

()

KafkaInAction_Chapter7/src/main/java/org/kafkainaction/model/Alert.java:24

↓ 1 callersMethodgetStageId

()

KafkaInAction_Chapter5/src/main/java/org/kafkainaction/model/Alert.java:24

↓ 1 callersMethodhasEnoughFunds

(Transaction transaction)

KafkaInAction_Chapter12/src/main/java/org/kafkainaction/kstreams2/TransactionTransformer.java:54

↓ 1 callersMethodisCriticalLevel

(String level)

KafkaInAction_Chapter7/src/main/java/org/kafkainaction/partitioner/AlertLevelPartitioner.java:43

↓ 1 callersMethodisCriticalLevel

(String level)

KafkaInAction_Chapter4/src/main/java/org/kafkainaction/partitioner/AlertLevelPartitioner.java:43

↓ 1 callersMethodreadConfig

()

KafkaInAction_Chapter4/src/main/java/org/kafkainaction/producer/FlumeSinkProducer.java:34

↓ 1 callersMethodsendCustomAlert

(Properties props, Alert alert)

KafkaInAction_Chapter7/src/test/java/org/kafkainaction/producer/AlertLevelPartitionerTest.java:108

↓ 1 callersMethodsendMessage

(Properties kaProperties)

KafkaInAction_Chapter7/src/main/java/org/kafkainaction/producer/AlertProducer.java:13

↓ 1 callersMethodstoresBuilder

(final String storeName, final Ser

KafkaInAction_Chapter12/src/main/java/org/kafkainaction/kstreams2/TransactionProcessor.java:168

↓ 1 callersMethodwithdrawFunds

(Transaction transaction)

KafkaInAction_Chapter12/src/main/java/org/kafkainaction/kstreams2/TransactionTransformer.java:95

MethodAlert

(int alertId, String stageId, String alertLevel, String alertMessage)

KafkaInAction_Chapter9/src/main/java/org/kafkainaction/model/Alert.java:14

MethodAlert

(int alertId, String stageId, String alertLevel, String alertMessage)

KafkaInAction_Chapter7/src/main/java/org/kafkainaction/model/Alert.java:12

MethodAlert

(int alertId, String stageId, String alertLevel, String alertMessage)

KafkaInAction_Chapter5/src/main/java/org/kafkainaction/model/Alert.java:12

MethodAlert

(int alertId, String stageId, String alertLevel, String alertMessage)

KafkaInAction_Chapter4/src/main/java/org/kafkainaction/model/Alert.java:12

MethodKinactionStopConsumer

(KafkaConsumer<String, String> consumer)

KafkaInAction_Chapter5/src/main/java/org/kafkainaction/consumer/KinactionStopConsumer.java:21

MethodTransactionProcessor

(final String transactionsInputTopicName, final String transactionSuccessTopicNa

KafkaInAction_Chapter12/src/main/java/org/kafkainaction/kstreams2/TransactionProcessor.java:44

MethodTransactionProcessorTest

()

KafkaInAction_Chapter12/src/test/java/org/kafkainaction/kstreams2/TransactionProcessorTest.java:53

MethodTransactionTransformer

()

KafkaInAction_Chapter12/src/main/java/org/kafkainaction/kstreams2/TransactionTransformer.java:27

MethodbalanceShouldBe300

()

KafkaInAction_Chapter12/src/test/java/org/kafkainaction/kstreams2/TransactionProcessorTest.java:162

Methodclose

()

KafkaInAction_Chapter9/src/main/java/org/kafkainaction/producer/AlertProducerMetricsInterceptor.java:35

Methodclose

()

KafkaInAction_Chapter9/src/main/java/org/kafkainaction/consumer/AlertConsumerMetricsInterceptor.java:43

Methodclose

()

KafkaInAction_Chapter7/src/main/java/org/kafkainaction/partitioner/AlertLevelPartitioner.java:51

Methodclose

()

KafkaInAction_Chapter7/src/main/java/org/kafkainaction/serde/AlertKeySerde.java:29

Methodclose

()

KafkaInAction_Chapter4/src/main/java/org/kafkainaction/partitioner/AlertLevelPartitioner.java:51

Methodclose

()

KafkaInAction_Chapter4/src/main/java/org/kafkainaction/serde/AlertKeySerde.java:30

Methodconfigure

(final Map<String, ?> map)

KafkaInAction_Chapter9/src/main/java/org/kafkainaction/producer/AlertProducerMetricsInterceptor.java:40

Methodconfigure

(final Map<String, ?> map)

KafkaInAction_Chapter9/src/main/java/org/kafkainaction/consumer/AlertConsumerMetricsInterceptor.java:48

Methodconfigure

(final Map<String, ?> map)

KafkaInAction_Chapter7/src/main/java/org/kafkainaction/partitioner/AlertLevelPartitioner.java:56

Methodconfigure

(final Map<String, ?> configs, final boolean isKey)

KafkaInAction_Chapter7/src/main/java/org/kafkainaction/serde/AlertKeySerde.java:24

Methodconfigure

(final Map<String, ?> configs, final boolean isKey)

KafkaInAction_Chapter5/src/main/java/org/kafkainaction/serde/AlertKeySerde.java:25

Methodconfigure

(final Map<String, ?> map)

KafkaInAction_Chapter4/src/main/java/org/kafkainaction/partitioner/AlertLevelPartitioner.java:56

Methodconfigure

(final Map<String, ?> configs, final boolean isKey)

KafkaInAction_Chapter4/src/main/java/org/kafkainaction/serde/AlertKeySerde.java:25

Methoddeserialize

(String topic, byte[] value)

KafkaInAction_Chapter9/src/main/java/org/kafkainaction/serde/AlertKeySerde.java:20

Methoddeserialize

(String topic, byte[] value)

KafkaInAction_Chapter7/src/main/java/org/kafkainaction/serde/AlertKeySerde.java:20

Methoddeserialize

(String topic, byte[] value)

KafkaInAction_Chapter5/src/main/java/org/kafkainaction/serde/AlertKeySerde.java:20

Methoddeserialize

(String topic, byte[] value)

KafkaInAction_Chapter4/src/main/java/org/kafkainaction/serde/AlertKeySerde.java:20

MethodgetAlertId

()

KafkaInAction_Chapter9/src/main/java/org/kafkainaction/model/Alert.java:21

MethodgetAlertId

()

KafkaInAction_Chapter7/src/main/java/org/kafkainaction/model/Alert.java:20

MethodgetAlertId

()

KafkaInAction_Chapter5/src/main/java/org/kafkainaction/model/Alert.java:20

MethodgetAlertId

()

KafkaInAction_Chapter4/src/main/java/org/kafkainaction/model/Alert.java:20

MethodgetAlertLevel

()

KafkaInAction_Chapter9/src/main/java/org/kafkainaction/model/Alert.java:33

MethodgetAlertLevel

()

KafkaInAction_Chapter5/src/main/java/org/kafkainaction/model/Alert.java:32

MethodgetAlertMessage

()

KafkaInAction_Chapter5/src/main/java/org/kafkainaction/model/Alert.java:36

MethodgetAlertMessages

(Properties kaConsumerProperties)

KafkaInAction_Chapter7/src/main/java/org/kafkainaction/consumer/AlertConsumer.java:17

Methodmain

(String[] args)

KafkaInAction_Chapter2/src/main/java/org/kafkainaction/producer/HelloWorldProducer.java:11

Methodmain

(String[] args)

KafkaInAction_Chapter2/src/main/java/org/kafkainaction/consumer/HelloWorldConsumer.java:19

Methodmain

(String[] args)

KafkaInAction_Chapter9/src/main/java/org/kafkainaction/producer/AlertProducer.java:13

Methodmain

(String[] args)

KafkaInAction_Chapter9/src/main/java/org/kafkainaction/consumer/AlertConsumer.java:16

Methodmain

(String[] args)

KafkaInAction_Chapter9/src/main/java/org/kafkainaction/util/CreateTopic.java:14

Methodmain

(String[] args)

KafkaInAction_Chapter12/src/test/java/org/kafkainaction/kstreams2/TransactionProducerTest.java:29

Methodmain

(String[] args)

KafkaInAction_Chapter12/src/test/java/org/kafkainaction/kstreams2/AccountProducerTest.java:31

Methodmain

(String[] args)

KafkaInAction_Chapter12/src/main/java/org/kafkainaction/kstreams2/TransactionProcessor.java:59

Methodmain

(String[] args)

KafkaInAction_Chapter5/src/main/java/org/kafkainaction/consumer/WebClickConsumer.java:18

Methodmain

(String[] args)

KafkaInAction_Chapter5/src/main/java/org/kafkainaction/consumer/AuditConsumer.java:21

Methodmain

(String[] args)

KafkaInAction_Chapter5/src/main/java/org/kafkainaction/consumer/ASyncCommit.java:23

Methodmain

(String[] args)

KafkaInAction_Chapter5/src/main/java/org/kafkainaction/consumer/AlertTrendConsumer.java:18

Methodmain

(String[] args)

KafkaInAction_Chapter4/src/main/java/org/kafkainaction/producer/FlumeSinkProducer.java:19

Methodmain

(String[] args)

KafkaInAction_Chapter4/src/main/java/org/kafkainaction/producer/AlertTrendingProducer.java:20

Methodmain

(String[] args)

KafkaInAction_Chapter4/src/main/java/org/kafkainaction/producer/AlertProducer.java:15

Methodmain

(String[] args)

KafkaInAction_Chapter4/src/main/java/org/kafkainaction/producer/AuditProducer.java:17

Methodmain

(String[] args)

KafkaInAction_Chapter4/src/main/java/org/kafkainaction/consumer/AlertConsumer.java:24

Methodmain

(String[] args)

KafkaInAction_Chapter11/src/main/java/org/kafkainaction/producer/AlertProducer.java:20

Methodmain

(String[] args)

KafkaInAction_Chapter11/src/main/java/org/kafkainaction/consumer/AlertConsumer.java:21

next →1–100 of 143, ranked by callers