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
configure
Set the specific Java Object Class Name @param props set specific.class.name to your specific Java Class Name @param isKey set it to false
custom-window/src/main/java/guru/learningjournal/kafka/examples/serde/JsonDeserializer.java:44
Method
configure
Set the specific Java Object Class Name @param props set specific.class.name to your specific Java Class Name @param isKey set it to false
counting-session/src/main/java/guru/learningjournal/kafka/examples/serde/JsonDeserializer.java:44
Method
configure
Set the specific Java Object Class Name @param props set specific.class.name to your specific Java Class Name @param isKey set it to false
ad-campaigns/src/main/java/guru/learningjournal/kafka/examples/serde/JsonDeserializer.java:44
Method
configure
Set the specific Java Object Class Name @param props set specific.class.name to your specific Java Class Name @param isKey set it to false
rewards-in-memory/src/main/java/guru/learningjournal/kafka/examples/serde/JsonDeserializer.java:44
Method
configure
Set the specific Java Object Class Name @param props set specific.class.name to your specific Java Class Name @param isKey set it to false
ktable-aggregate-query/src/main/java/guru/learningjournal/kafka/examples/serde/JsonDeserializer.java:44
Method
configure
Set the specific Java Object Class Name @param props set specific.class.name to your specific Java Class Name @param isKey set it to false
last-login/src/main/java/guru/learningjournal/kafka/examples/serde/JsonDeserializer.java:44
Method
configure
Set the specific Java Object Class Name @param props set specific.class.name to your specific Java Class Name @param isKey set it to false
stream-join/src/main/java/guru/learningjournal/kafka/examples/serde/JsonDeserializer.java:44
Method
configure
Set the specific Java Object Class Name @param props set specific.class.name to your specific Java Class Name @param isKey set it to false
kstream-aggregate/src/main/java/guru/learningjournal/kafka/examples/serde/JsonDeserializer.java:44
Method
configure
Set the specific Java Object Class Name @param props set specific.class.name to your specific Java Class Name @param isKey set it to false
top3-inventories/src/main/java/guru/learningjournal/kafka/examples/serde/JsonDeserializer.java:44
Method
configure
(Map<String, ?> map)
partitioned-producer/src/main/java/guru/learningjournal/kafka/examples/OddEvenPartitioner.java:61
Method
configure
(Map<String, ?> config, boolean isKey)
transactional-producer/src/main/java/guru/learningjournal/kafka/examples/JsonSerializer.java:36
Method
configure
Set the specific Java Object Class Name @param props set specific.class.name to your specific Java Class Name @param isKey set it to false
time-check/src/main/java/guru/learningjournal/kafka/examples/serde/JsonDeserializer.java:44
Method
configure
Set the specific Java Object Class Name @param props set specific.class.name to your specific Java Class Name @param isKey set it to false
rewards-table/src/main/java/guru/learningjournal/kafka/examples/serde/JsonDeserializer.java:44
Method
configure
(Map<String, ?> config, boolean isKey)
json-producer/src/main/java/guru/learningjournal/kafka/examples/JsonSerializer.java:39
Method
configure
Set the specific Java Object Class Name @param props set specific.class.name to your specific Java Class Name @param isKey set it to false
topology-test/src/main/java/guru/learningjournal/kafka/examples/serde/JsonDeserializer.java:44
Method
configure
Set the specific Java Object Class Name @param props set specific.class.name to your specific Java Class Name @param isKey set it to false
counting-window/src/main/java/guru/learningjournal/kafka/examples/serde/JsonDeserializer.java:44
Method
configure
(Map<String, ?> config, boolean isKey)
pos-simulator/src/main/java/guru/learningjournal/kafka/examples/serde/JsonSerializer.java:34
Method
configure
(Map<String, ?> map, boolean b)
json-consumer/src/main/java/guru/learningjournal/kafka/examples/JsonDeserializer.java:35
Method
configure
Set the specific Java Object Class Name @param props set specific.class.name to your specific Java Class Name @param isKey set it to false
pos-fanout/src/main/java/guru/learningjournal/kafka/examples/serde/JsonDeserializer.java:44
Method
configure
Set the specific Java Object Class Name @param props set specific.class.name to your specific Java Class Name @param isKey set it to false
ktable-aggregate/src/main/java/guru/learningjournal/kafka/examples/serde/JsonDeserializer.java:44
Method
configure
Set the specific Java Object Class Name @param props set specific.class.name to your specific Java Class Name @param isKey set it to false
custom-sink/src/main/java/guru/learningjournal/kafka/examples/serde/JsonDeserializer.java:44
Method
deserialize
Deserialize to a POJO @param topic topic name @param data message bytes @return Specific Java Object
custom-window/src/main/java/guru/learningjournal/kafka/examples/serde/JsonDeserializer.java:57
Method
deserialize
Deserialize to a POJO @param topic topic name @param data message bytes @return Specific Java Object
counting-session/src/main/java/guru/learningjournal/kafka/examples/serde/JsonDeserializer.java:57
Method
deserialize
Deserialize to a POJO @param topic topic name @param data message bytes @return Specific Java Object
ad-campaigns/src/main/java/guru/learningjournal/kafka/examples/serde/JsonDeserializer.java:57
Method
deserialize
Deserialize to a POJO @param topic topic name @param data message bytes @return Specific Java Object
rewards-in-memory/src/main/java/guru/learningjournal/kafka/examples/serde/JsonDeserializer.java:57
Method
deserialize
Deserialize to a POJO @param topic topic name @param data message bytes @return Specific Java Object
ktable-aggregate-query/src/main/java/guru/learningjournal/kafka/examples/serde/JsonDeserializer.java:57
Method
deserialize
Deserialize to a POJO @param topic topic name @param data message bytes @return Specific Java Object
last-login/src/main/java/guru/learningjournal/kafka/examples/serde/JsonDeserializer.java:57
Method
deserialize
Deserialize to a POJO @param topic topic name @param data message bytes @return Specific Java Object
stream-join/src/main/java/guru/learningjournal/kafka/examples/serde/JsonDeserializer.java:57
Method
deserialize
Deserialize to a POJO @param topic topic name @param data message bytes @return Specific Java Object
kstream-aggregate/src/main/java/guru/learningjournal/kafka/examples/serde/JsonDeserializer.java:57
Method
deserialize
Deserialize to a POJO @param topic topic name @param data message bytes @return Specific Java Object
top3-inventories/src/main/java/guru/learningjournal/kafka/examples/serde/JsonDeserializer.java:57
Method
deserialize
Deserialize to a POJO @param topic topic name @param data message bytes @return Specific Java Object
time-check/src/main/java/guru/learningjournal/kafka/examples/serde/JsonDeserializer.java:57
Method
deserialize
Deserialize to a POJO @param topic topic name @param data message bytes @return Specific Java Object
rewards-table/src/main/java/guru/learningjournal/kafka/examples/serde/JsonDeserializer.java:57
Method
deserialize
Deserialize to a POJO @param topic topic name @param data message bytes @return Specific Java Object
topology-test/src/main/java/guru/learningjournal/kafka/examples/serde/JsonDeserializer.java:57
Method
deserialize
Deserialize to a POJO @param topic topic name @param data message bytes @return Specific Java Object
counting-window/src/main/java/guru/learningjournal/kafka/examples/serde/JsonDeserializer.java:57
Method
deserialize
Deserialize to a JsonNode @param topic topic name @param data message bytes @return JsonNode
json-consumer/src/main/java/guru/learningjournal/kafka/examples/JsonDeserializer.java:46
Method
deserialize
Deserialize to a POJO @param topic topic name @param data message bytes @return Specific Java Object
pos-fanout/src/main/java/guru/learningjournal/kafka/examples/serde/JsonDeserializer.java:57
Method
deserialize
Deserialize to a POJO @param topic topic name @param data message bytes @return Specific Java Object
ktable-aggregate/src/main/java/guru/learningjournal/kafka/examples/serde/JsonDeserializer.java:57
Method
deserialize
Deserialize to a POJO @param topic topic name @param data message bytes @return Specific Java Object
custom-sink/src/main/java/guru/learningjournal/kafka/examples/serde/JsonDeserializer.java:57
Method
extract
(ConsumerRecord<Object, Object> consumerRecord, long prevTime)
counting-session/src/main/java/guru/learningjournal/kafka/examples/common/AppTimestampExtractor.java:31
Method
extract
(ConsumerRecord<Object, Object> consumerRecord, long prevTime)
stream-join/src/main/java/guru/learningjournal/kafka/examples/common/AppTimeExtractor.java:34
Method
extract
(ConsumerRecord<Object, Object> consumerRecord, long prevTime)
stream-join/src/main/java/guru/learningjournal/kafka/examples/common/AppTimeExtractor.java:47
Method
extract
(ConsumerRecord<Object, Object> consumerRecord, long prevTime)
time-check/src/main/java/guru/learningjournal/kafka/examples/InvoiceTimeExtractor.java:31
Method
extract
(ConsumerRecord<Object, Object> consumerRecord, long prevTime)
counting-window/src/main/java/guru/learningjournal/kafka/examples/InvoiceTimeExtractor.java:31
Method
get
(int field$)
pojo-from-avro/src/main/java/guru/learningjournal/kafka/examples/types/Notification.java:44
Method
get
(int field$)
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosLineItem.java:47
Method
get
(int field$)
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/types/DeliveryAddress.java:47
Method
get
(int field$)
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosLineItem.java:47
Method
get
(int field$)
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/DeliveryAddress.java:47
Method
get
(int field$)
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/Notification.java:44
Method
get
(int field$)
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/HadoopRecord.java:77
Method
getAdClicks
()
ad-campaigns/src/main/java/guru/learningjournal/kafka/examples/types/CampaignPerformance.java:54
Method
getAdImpressions
()
ad-campaigns/src/main/java/guru/learningjournal/kafka/examples/types/CampaignPerformance.java:39
Method
getAdditionalProperties
()
custom-window/src/main/java/guru/learningjournal/kafka/examples/types/StockTicker.java:76
Method
getAdditionalProperties
()
pojo-from-json/src/main/java/guru/learningjournal/kafka/examples/types/Notification.java:96
Method
getAdditionalProperties
()
custom-sink/src/main/java/guru/learningjournal/kafka/examples/types/GenericRecord.java:53
Method
getAddressLine
()
rewards-in-memory/src/main/java/guru/learningjournal/kafka/examples/types/DeliveryAddress.java:30
Method
getAddressLine
Gets the value of the 'AddressLine' field. @return The value of the 'AddressLine' field.
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/types/DeliveryAddress.java:75
Method
getAddressLine
Gets the value of the 'AddressLine' field. @return The value.
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/types/DeliveryAddress.java:254
Method
getAddressLine
()
time-check/src/main/java/guru/learningjournal/kafka/examples/types/DeliveryAddress.java:30
Method
getAddressLine
()
rewards-table/src/main/java/guru/learningjournal/kafka/examples/types/DeliveryAddress.java:30
Method
getAddressLine
()
pos-simulator/src/main/java/guru/learningjournal/kafka/examples/types/DeliveryAddress.java:30
Method
getAddressLine
Gets the value of the 'AddressLine' field. @return The value of the 'AddressLine' field.
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/DeliveryAddress.java:75
Method
getAddressLine
Gets the value of the 'AddressLine' field. @return The value.
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/DeliveryAddress.java:254
Method
getAddressLine
()
pos-fanout/src/main/java/guru/learningjournal/kafka/examples/types/DeliveryAddress.java:30
Method
getAmount
()
stream-join/src/main/java/guru/learningjournal/kafka/examples/types/PaymentRequest.java:93
Method
getAvgSalary
()
ktable-aggregate-query/src/main/java/guru/learningjournal/kafka/examples/types/DepartmentAggregate.java:54
Method
getAvgSalary
()
kstream-aggregate/src/main/java/guru/learningjournal/kafka/examples/types/DepartmentAggregate.java:54
Method
getAvgSalary
()
ktable-aggregate/src/main/java/guru/learningjournal/kafka/examples/types/DepartmentAggregate.java:54
Method
getCESS
()
rewards-in-memory/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:263
Method
getCESS
Gets the value of the 'CESS' field. @return The value of the 'CESS' field.
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:343
Method
getCESS
Gets the value of the 'CESS' field. @return The value.
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:1126
Method
getCESS
()
time-check/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:263
Method
getCESS
()
rewards-table/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:263
Method
getCESS
()
pos-simulator/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:198
Method
getCESS
Gets the value of the 'CESS' field. @return The value of the 'CESS' field.
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:343
Method
getCESS
Gets the value of the 'CESS' field. @return The value.
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:1126
Method
getCESS
()
pos-fanout/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:263
Method
getCGST
()
rewards-in-memory/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:233
Method
getCGST
Gets the value of the 'CGST' field. @return The value of the 'CGST' field.
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:311
Method
getCGST
Gets the value of the 'CGST' field. @return The value.
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:1048
Method
getCGST
()
time-check/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:233
Method
getCGST
()
rewards-table/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:233
Method
getCGST
()
pos-simulator/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:178
Method
getCGST
Gets the value of the 'CGST' field. @return The value of the 'CGST' field.
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:311
Method
getCGST
Gets the value of the 'CGST' field. @return The value.
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:1048
Method
getCGST
()
pos-fanout/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:233
Method
getCampaigner
()
ad-campaigns/src/main/java/guru/learningjournal/kafka/examples/types/AdImpression.java:36
Method
getCampaigner
()
ad-campaigns/src/main/java/guru/learningjournal/kafka/examples/types/CampaignPerformance.java:24
Method
getCampaigner
()
topology-test/src/main/java/guru/learningjournal/kafka/examples/types/AdImpression.java:36
Method
getCashierID
()
rewards-in-memory/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:128
Method
getCashierID
Gets the value of the 'CashierID' field. @return The value of the 'CashierID' field.
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:199
Method
getCashierID
Gets the value of the 'CashierID' field. @return The value.
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:775
Method
getCashierID
()
time-check/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:128
Method
getCashierID
()
rewards-table/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:128
Method
getCashierID
()
pos-simulator/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:108
Method
getCashierID
Gets the value of the 'CashierID' field. @return The value of the 'CashierID' field.
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:199
Method
getCashierID
Gets the value of the 'CashierID' field. @return The value.
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:775
Method
getCashierID
()
pos-fanout/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:128
Method
getCity
()
rewards-in-memory/src/main/java/guru/learningjournal/kafka/examples/types/DeliveryAddress.java:45
Method
getCity
Gets the value of the 'City' field. @return The value of the 'City' field.
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/types/DeliveryAddress.java:91
← previous
next →
601–700 of 1,924, ranked by callers