Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/LearningJournal/Kafka-Streams-Real-time-Stream-Processing
/ functions
Functions
1,924 in github.com/LearningJournal/Kafka-Streams-Real-time-Stream-Processing
⨍
Functions
1,924
◇
Types & classes
246
Method
JsonDeserializer
()
last-login/src/main/java/guru/learningjournal/kafka/examples/serde/JsonDeserializer.java:34
Method
JsonDeserializer
()
stream-join/src/main/java/guru/learningjournal/kafka/examples/serde/JsonDeserializer.java:34
Method
JsonDeserializer
()
kstream-aggregate/src/main/java/guru/learningjournal/kafka/examples/serde/JsonDeserializer.java:34
Method
JsonDeserializer
()
top3-inventories/src/main/java/guru/learningjournal/kafka/examples/serde/JsonDeserializer.java:34
Method
JsonDeserializer
()
time-check/src/main/java/guru/learningjournal/kafka/examples/serde/JsonDeserializer.java:34
Method
JsonDeserializer
()
rewards-table/src/main/java/guru/learningjournal/kafka/examples/serde/JsonDeserializer.java:34
Method
JsonDeserializer
()
topology-test/src/main/java/guru/learningjournal/kafka/examples/serde/JsonDeserializer.java:34
Method
JsonDeserializer
()
counting-window/src/main/java/guru/learningjournal/kafka/examples/serde/JsonDeserializer.java:34
Method
JsonDeserializer
()
json-consumer/src/main/java/guru/learningjournal/kafka/examples/JsonDeserializer.java:31
Method
JsonDeserializer
()
pos-fanout/src/main/java/guru/learningjournal/kafka/examples/serde/JsonDeserializer.java:34
Method
JsonDeserializer
()
ktable-aggregate/src/main/java/guru/learningjournal/kafka/examples/serde/JsonDeserializer.java:34
Method
JsonDeserializer
()
custom-sink/src/main/java/guru/learningjournal/kafka/examples/serde/JsonDeserializer.java:34
Method
JsonSerializer
()
custom-window/src/main/java/guru/learningjournal/kafka/examples/serde/JsonSerializer.java:33
Method
JsonSerializer
()
counting-session/src/main/java/guru/learningjournal/kafka/examples/serde/JsonSerializer.java:33
Method
JsonSerializer
()
ad-campaigns/src/main/java/guru/learningjournal/kafka/examples/serde/JsonSerializer.java:33
Method
JsonSerializer
()
rewards-in-memory/src/main/java/guru/learningjournal/kafka/examples/serde/JsonSerializer.java:33
Method
JsonSerializer
()
ktable-aggregate-query/src/main/java/guru/learningjournal/kafka/examples/serde/JsonSerializer.java:33
Method
JsonSerializer
()
last-login/src/main/java/guru/learningjournal/kafka/examples/serde/JsonSerializer.java:33
Method
JsonSerializer
()
stream-join/src/main/java/guru/learningjournal/kafka/examples/serde/JsonSerializer.java:33
Method
JsonSerializer
()
kstream-aggregate/src/main/java/guru/learningjournal/kafka/examples/serde/JsonSerializer.java:33
Method
JsonSerializer
()
top3-inventories/src/main/java/guru/learningjournal/kafka/examples/serde/JsonSerializer.java:33
Method
JsonSerializer
()
transactional-producer/src/main/java/guru/learningjournal/kafka/examples/JsonSerializer.java:32
Method
JsonSerializer
()
time-check/src/main/java/guru/learningjournal/kafka/examples/serde/JsonSerializer.java:33
Method
JsonSerializer
()
rewards-table/src/main/java/guru/learningjournal/kafka/examples/serde/JsonSerializer.java:33
Method
JsonSerializer
()
json-producer/src/main/java/guru/learningjournal/kafka/examples/JsonSerializer.java:35
Method
JsonSerializer
()
topology-test/src/main/java/guru/learningjournal/kafka/examples/serde/JsonSerializer.java:33
Method
JsonSerializer
()
counting-window/src/main/java/guru/learningjournal/kafka/examples/serde/JsonSerializer.java:33
Method
JsonSerializer
()
pos-simulator/src/main/java/guru/learningjournal/kafka/examples/serde/JsonSerializer.java:30
Method
JsonSerializer
()
pos-fanout/src/main/java/guru/learningjournal/kafka/examples/serde/JsonSerializer.java:33
Method
JsonSerializer
()
ktable-aggregate/src/main/java/guru/learningjournal/kafka/examples/serde/JsonSerializer.java:33
Method
JsonSerializer
()
custom-sink/src/main/java/guru/learningjournal/kafka/examples/serde/JsonSerializer.java:33
Method
Notification
Default constructor. Note that this does not initialize fields to their default values from the schema. If that is desired then one should use <code
pojo-from-avro/src/main/java/guru/learningjournal/kafka/examples/types/Notification.java:26
Method
Notification
Default constructor. Note that this does not initialize fields to their default values from the schema. If that is desired then one should use <code
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/Notification.java:26
Method
NotificationSerde
()
rewards-in-memory/src/main/java/guru/learningjournal/kafka/examples/PosSerdes.java:56
Method
NotificationSerde
()
rewards-table/src/main/java/guru/learningjournal/kafka/examples/PosSerdes.java:56
Method
NotificationSerde
()
pos-fanout/src/main/java/guru/learningjournal/kafka/examples/PosSerdes.java:56
Method
PaymentConfirmationSerde
()
stream-join/src/main/java/guru/learningjournal/kafka/examples/common/AppSerdes.java:53
Method
PaymentRequestSerde
()
stream-join/src/main/java/guru/learningjournal/kafka/examples/common/AppSerdes.java:37
Method
PosInvoice
Default constructor. Note that this does not initialize fields to their default values from the schema. If that is desired then one should use <code
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:39
Method
PosInvoice
Default constructor. Note that this does not initialize fields to their default values from the schema. If that is desired then one should use <code
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:39
Method
PosInvoiceSerde
()
counting-session/src/main/java/guru/learningjournal/kafka/examples/common/AppSerdes.java:37
Method
PosInvoiceSerde
()
rewards-in-memory/src/main/java/guru/learningjournal/kafka/examples/PosSerdes.java:40
Method
PosInvoiceSerde
()
time-check/src/main/java/guru/learningjournal/kafka/examples/PosSerdes.java:39
Method
PosInvoiceSerde
()
rewards-table/src/main/java/guru/learningjournal/kafka/examples/PosSerdes.java:40
Method
PosInvoiceSerde
()
counting-window/src/main/java/guru/learningjournal/kafka/examples/AppSerdes.java:37
Method
PosInvoiceSerde
()
pos-fanout/src/main/java/guru/learningjournal/kafka/examples/PosSerdes.java:40
Method
PosLineItem
Default constructor. Note that this does not initialize fields to their default values from the schema. If that is desired then one should use <code
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosLineItem.java:27
Method
PosLineItem
Default constructor. Note that this does not initialize fields to their default values from the schema. If that is desired then one should use <code
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosLineItem.java:27
Method
ProductGenerator
()
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/datagenerator/ProductGenerator.java:34
Method
ProductGenerator
()
pos-simulator/src/main/java/guru/learningjournal/kafka/examples/datagenerator/ProductGenerator.java:34
Method
RunnableConsumer
(int id, String groupID, List<String> topics)
json-consumer/src/main/java/guru/learningjournal/kafka/examples/RunnableConsumer.java:47
Method
RunnableProducer
(int id, KafkaProducer<String, PosInvoice> producer, String topicName, int produceSpeed)
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/RunnableProducer.java:38
Method
RunnableProducer
(int id, KafkaProducer<String, PosInvoice> producer, String topicName, int produceSpeed)
pos-simulator/src/main/java/guru/learningjournal/kafka/examples/RunnableProducer.java:36
Method
StockData
Default constructor. Note that this does not initialize fields to their default values from the schema. If that is desired then one should use <code
avro-consumer/src/main/java/guru/learningjournal/kafka/examples/StockData.java:35
Method
StockData
Default constructor. Note that this does not initialize fields to their default values from the schema. If that is desired then one should use <code
avro-producer/src/main/java/guru/learningjournal/kafka/examples/StockData.java:36
Method
StockPunctuator
(ProcessorContext context, KeyValueStore<String, TickerStack> stateStore)
custom-window/src/main/java/guru/learningjournal/kafka/examples/StockPunctuator.java:33
Method
StockTickerSerde
()
custom-window/src/main/java/guru/learningjournal/kafka/examples/AppSerdes.java:33
Method
TableMapSerde
()
custom-sink/src/main/java/guru/learningjournal/kafka/examples/AppSerdes.java:53
Method
TickerStackSerde
()
custom-window/src/main/java/guru/learningjournal/kafka/examples/AppSerdes.java:49
Method
Top3NewsTypesSerde
()
top3-inventories/src/main/java/guru/learningjournal/kafka/examples/common/AppSerdes.java:87
Method
UserDetailsSerde
()
last-login/src/main/java/guru/learningjournal/kafka/examples/common/AppSerdes.java:37
Method
UserLoginSerde
()
last-login/src/main/java/guru/learningjournal/kafka/examples/common/AppSerdes.java:54
Method
build
()
pojo-from-avro/src/main/java/guru/learningjournal/kafka/examples/types/Notification.java:376
Method
build
()
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosLineItem.java:445
Method
build
()
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/types/DeliveryAddress.java:445
Method
build
()
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:1313
Method
build
()
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosLineItem.java:445
Method
build
()
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/DeliveryAddress.java:445
Method
build
()
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/Notification.java:376
Method
build
()
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/HadoopRecord.java:1135
Method
clearAddressLine
Clears the value of the 'AddressLine' field. @return This builder.
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/types/DeliveryAddress.java:283
Method
clearAddressLine
Clears the value of the 'AddressLine' field. @return This builder.
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/DeliveryAddress.java:283
Method
clearCESS
Clears the value of the 'CESS' field. @return This builder.
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:1155
Method
clearCESS
Clears the value of the 'CESS' field. @return This builder.
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:1155
Method
clearCGST
Clears the value of the 'CGST' field. @return This builder.
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:1077
Method
clearCGST
Clears the value of the 'CGST' field. @return This builder.
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:1077
Method
clearCashierID
Clears the value of the 'CashierID' field. @return This builder.
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:804
Method
clearCashierID
Clears the value of the 'CashierID' field. @return This builder.
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:804
Method
clearCity
Clears the value of the 'City' field. @return This builder.
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/types/DeliveryAddress.java:322
Method
clearCity
Clears the value of the 'City' field. @return This builder.
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/DeliveryAddress.java:322
Method
clearCity
Clears the value of the 'City' field. @return This builder.
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/HadoopRecord.java:856
Method
clearClose
Clears the value of the 'close' field. @return This builder.
avro-consumer/src/main/java/guru/learningjournal/kafka/examples/StockData.java:718
Method
clearClose
Clears the value of the 'close' field. @return This builder.
avro-producer/src/main/java/guru/learningjournal/kafka/examples/StockData.java:719
Method
clearContactNumber
Clears the value of the 'ContactNumber' field. @return This builder.
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/types/DeliveryAddress.java:439
Method
clearContactNumber
Clears the value of the 'ContactNumber' field. @return This builder.
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/DeliveryAddress.java:439
Method
clearCreatedTime
Clears the value of the 'CreatedTime' field. @return This builder.
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:687
Method
clearCreatedTime
Clears the value of the 'CreatedTime' field. @return This builder.
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:687
Method
clearCreatedTime
Clears the value of the 'CreatedTime' field. @return This builder.
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/HadoopRecord.java:622
Method
clearCustomerCardNo
Clears the value of the 'CustomerCardNo' field. @return This builder.
pojo-from-avro/src/main/java/guru/learningjournal/kafka/examples/types/Notification.java:292
Method
clearCustomerCardNo
Clears the value of the 'CustomerCardNo' field. @return This builder.
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:882
Method
clearCustomerCardNo
Clears the value of the 'CustomerCardNo' field. @return This builder.
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:882
Method
clearCustomerCardNo
Clears the value of the 'CustomerCardNo' field. @return This builder.
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/Notification.java:292
Method
clearCustomerType
Clears the value of the 'CustomerType' field. @return This builder.
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:843
Method
clearCustomerType
Clears the value of the 'CustomerType' field. @return This builder.
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:843
Method
clearCustomerType
Clears the value of the 'CustomerType' field. @return This builder.
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/HadoopRecord.java:739
Method
clearDeliveryType
Clears the value of the 'DeliveryType' field. @return This builder.
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:1194
Method
clearDeliveryType
Clears the value of the 'DeliveryType' field. @return This builder.
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:1194
Method
clearDeliveryType
Clears the value of the 'DeliveryType' field. @return This builder.
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/HadoopRecord.java:817
Method
clearEarnedLoyaltyPoints
Clears the value of the 'EarnedLoyaltyPoints' field. @return This builder.
pojo-from-avro/src/main/java/guru/learningjournal/kafka/examples/types/Notification.java:370
Method
clearEarnedLoyaltyPoints
Clears the value of the 'EarnedLoyaltyPoints' field. @return This builder.
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/Notification.java:370
← previous
next →
401–500 of 1,924, ranked by callers