MCPcopy Create free account

hub / github.com/LearningJournal/Kafka-Streams-Real-time-Stream-Processing / types & classes

Types & classes246 in github.com/LearningJournal/Kafka-Streams-Real-time-Stream-Processing

⨍ Functions 1,924◇ Types & classes 246
ClassAdClick
ad-campaigns/src/main/java/guru/learningjournal/kafka/examples/types/AdClick.java:9
ClassAdClick
top3-inventories/src/main/java/guru/learningjournal/kafka/examples/types/AdClick.java:9
ClassAdClick
topology-test/src/main/java/guru/learningjournal/kafka/examples/types/AdClick.java:9
ClassAdClickSerde
ad-campaigns/src/main/java/guru/learningjournal/kafka/examples/common/AppSerdes.java:69
ClassAdClickSerde
top3-inventories/src/main/java/guru/learningjournal/kafka/examples/common/AppSerdes.java:54
ClassAdClickSerde
topology-test/src/main/java/guru/learningjournal/kafka/examples/common/AppSerdes.java:69
ClassAdImpression
ad-campaigns/src/main/java/guru/learningjournal/kafka/examples/types/AdImpression.java:9
ClassAdImpression
topology-test/src/main/java/guru/learningjournal/kafka/examples/types/AdImpression.java:9
ClassAdImpressionSerde
ad-campaigns/src/main/java/guru/learningjournal/kafka/examples/common/AppSerdes.java:53
ClassAdImpressionSerde
topology-test/src/main/java/guru/learningjournal/kafka/examples/common/AppSerdes.java:53
ClassAdInventories
top3-inventories/src/main/java/guru/learningjournal/kafka/examples/types/AdInventories.java:9
ClassAdInventoriesSerde
top3-inventories/src/main/java/guru/learningjournal/kafka/examples/common/AppSerdes.java:37
ClassAddressGenerator
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/datagenerator/AddressGenerator.java:25
ClassAddressGenerator
pos-simulator/src/main/java/guru/learningjournal/kafka/examples/datagenerator/AddressGenerator.java:25
ClassAgeCountDemo
age-count/src/main/java/guru/learningjournal/kafka/examples/AgeCountDemo.java:32
ClassAppConfigs
Application Config @author prashant @author www.learningjournal.guru
custom-window/src/main/java/guru/learningjournal/kafka/examples/AppConfigs.java:25
ClassAppConfigs
Application Configs @author prashant @author www.learningjournal.guru
counting-session/src/main/java/guru/learningjournal/kafka/examples/common/AppConfigs.java:24
ClassAppConfigs
Application Config @author prashant @author www.learningjournal.guru
ad-campaigns/src/main/java/guru/learningjournal/kafka/examples/common/AppConfigs.java:25
ClassAppConfigs
Configurations for the PosFanOutApp @author prashant @author www.learningjournal.guru
rewards-in-memory/src/main/java/guru/learningjournal/kafka/examples/AppConfigs.java:24
ClassAppConfigs
Application Config @author prashant @author www.learningjournal.guru
ktable-aggregate-query/src/main/java/guru/learningjournal/kafka/examples/AppConfigs.java:25
ClassAppConfigs
Application Config @author prashant @author www.learningjournal.guru
last-login/src/main/java/guru/learningjournal/kafka/examples/common/AppConfigs.java:25
ClassAppConfigs
Application Config @author prashant @author www.learningjournal.guru
stream-join/src/main/java/guru/learningjournal/kafka/examples/common/AppConfigs.java:25
ClassAppConfigs
Application Config @author prashant @author www.learningjournal.guru
kstream-aggregate/src/main/java/guru/learningjournal/kafka/examples/AppConfigs.java:24
ClassAppConfigs
Application Config @author prashant @author www.learningjournal.guru
top3-inventories/src/main/java/guru/learningjournal/kafka/examples/common/AppConfigs.java:25
ClassAppConfigs
Application Configs @author prashant @author www.learningjournal.guru
hello-producer/src/main/java/guru/learningjournal/kafka/examples/common/AppConfigs.java:24
ClassAppConfigs
Application Configs @author prashant @author www.learningjournal.guru
time-check/src/main/java/guru/learningjournal/kafka/examples/AppConfigs.java:24
ClassAppConfigs
Configurations for the PosFanOutApp @author prashant @author www.learningjournal.guru
rewards-table/src/main/java/guru/learningjournal/kafka/examples/AppConfigs.java:24
ClassAppConfigs
Application Config @author prashant @author www.learningjournal.guru
topology-test/src/main/java/guru/learningjournal/kafka/examples/common/AppConfigs.java:25
ClassAppConfigs
Application Configs @author prashant @author www.learningjournal.guru
counting-window/src/main/java/guru/learningjournal/kafka/examples/AppConfigs.java:24
ClassAppConfigs
Application Config @author prashant @author www.learningjournal.guru
age-count/src/main/java/guru/learningjournal/kafka/examples/AppConfigs.java:24
ClassAppConfigs
Application Config @author prashant @author www.learningjournal.guru
ktable-aggregate/src/main/java/guru/learningjournal/kafka/examples/AppConfigs.java:25
ClassAppConfigs
Application Config @author prashant @author www.learningjournal.guru
custom-sink/src/main/java/guru/learningjournal/kafka/examples/AppConfigs.java:27
ClassAppEmbeddedTest
Integration Testing for campaign performance @author prashant @author www.learningjournal.guru
topology-test/src/test/java/guru/learningjournal/kafka/examples/AppEmbeddedTest.java:50
ClassAppRestService
ktable-aggregate-query/src/main/java/guru/learningjournal/kafka/examples/AppRestService.java:24
ClassAppSerdes
custom-window/src/main/java/guru/learningjournal/kafka/examples/AppSerdes.java:29
ClassAppSerdes
Factory class for Serdes @author prashant @author www.learningjournal.guru
counting-session/src/main/java/guru/learningjournal/kafka/examples/common/AppSerdes.java:33
ClassAppSerdes
Application level Serdes @author prashant @author www.learningjournal.guru
ad-campaigns/src/main/java/guru/learningjournal/kafka/examples/common/AppSerdes.java:35
ClassAppSerdes
Application level Serdes @author prashant @author www.learningjournal.guru
ktable-aggregate-query/src/main/java/guru/learningjournal/kafka/examples/AppSerdes.java:34
ClassAppSerdes
Application level Serdes @author prashant @author www.learningjournal.guru
last-login/src/main/java/guru/learningjournal/kafka/examples/common/AppSerdes.java:34
ClassAppSerdes
Application level Serdes @author prashant @author www.learningjournal.guru
stream-join/src/main/java/guru/learningjournal/kafka/examples/common/AppSerdes.java:34
ClassAppSerdes
Application level Serdes @author prashant @author www.learningjournal.guru
kstream-aggregate/src/main/java/guru/learningjournal/kafka/examples/AppSerdes.java:34
ClassAppSerdes
Application level Serdes @author prashant @author www.learningjournal.guru
top3-inventories/src/main/java/guru/learningjournal/kafka/examples/common/AppSerdes.java:35
ClassAppSerdes
Application level Serdes @author prashant @author www.learningjournal.guru
topology-test/src/main/java/guru/learningjournal/kafka/examples/common/AppSerdes.java:35
ClassAppSerdes
Factory class for Serdes @author prashant @author www.learningjournal.guru
counting-window/src/main/java/guru/learningjournal/kafka/examples/AppSerdes.java:33
ClassAppSerdes
Application level Serdes @author prashant @author www.learningjournal.guru
ktable-aggregate/src/main/java/guru/learningjournal/kafka/examples/AppSerdes.java:34
ClassAppSerdes
Application level Serdes @author prashant @author www.learningjournal.guru
custom-sink/src/main/java/guru/learningjournal/kafka/examples/AppSerdes.java:34
ClassAppTimeExtractor
Application Specific Timestamp Extractors @author prashant @author www.learningjournal.guru
stream-join/src/main/java/guru/learningjournal/kafka/examples/common/AppTimeExtractor.java:30
ClassAppTimestampExtractor
Custom TimestampExtractor for the Application @author prashant @author www.learningjournal.guru
counting-session/src/main/java/guru/learningjournal/kafka/examples/common/AppTimestampExtractor.java:29
ClassAppTopology
topology-test/src/main/java/guru/learningjournal/kafka/examples/AppTopology.java:30
ClassAppTopologyTest
Unit Testing for Campaign Performance @author prashant @author www.learningjournal.guru
topology-test/src/test/java/guru/learningjournal/kafka/examples/AppTopologyTest.java:48
ClassAvroConsumer
Avro consumer for StockData object @author prashant @author www.learningjournal.guru
avro-consumer/src/main/java/guru/learningjournal/kafka/examples/AvroConsumer.java:41
ClassAvroProducerDemo
Avro producer for StockData @author prashant @author www.learningjournal.guru
avro-producer/src/main/java/guru/learningjournal/kafka/examples/AvroProducerDemo.java:44
ClassBuilder
RecordBuilder for Notification instances.
pojo-from-avro/src/main/java/guru/learningjournal/kafka/examples/types/Notification.java:159
ClassBuilder
RecordBuilder for StockData instances.
avro-consumer/src/main/java/guru/learningjournal/kafka/examples/StockData.java:348
ClassBuilder
RecordBuilder for PosLineItem instances.
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosLineItem.java:180
ClassBuilder
RecordBuilder for DeliveryAddress instances.
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/types/DeliveryAddress.java:180
ClassBuilder
RecordBuilder for PosInvoice instances.
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:432
ClassBuilder
RecordBuilder for PosLineItem instances.
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosLineItem.java:180
ClassBuilder
RecordBuilder for DeliveryAddress instances.
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/DeliveryAddress.java:180
ClassBuilder
RecordBuilder for PosInvoice instances.
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:432
ClassBuilder
RecordBuilder for Notification instances.
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/Notification.java:159
ClassBuilder
RecordBuilder for HadoopRecord instances.
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/HadoopRecord.java:390
ClassBuilder
RecordBuilder for StockData instances.
avro-producer/src/main/java/guru/learningjournal/kafka/examples/StockData.java:349
ClassCallbackProducer
A Kafka producer that sends numEvents (# of messages) to a given topicName Producer demonstrates callback implementation @author prashant @author www
callback-producer/src/main/java/guru/learningjournal/kafka/examples/CallbackProducer.java:34
ClassCampaignPerformance
ad-campaigns/src/main/java/guru/learningjournal/kafka/examples/types/CampaignPerformance.java:9
ClassCampaignPerformance
topology-test/src/main/java/guru/learningjournal/kafka/examples/types/CampaignPerformance.java:9
ClassCampaignPerformanceApp
ad-campaigns/src/main/java/guru/learningjournal/kafka/examples/CampaignPerformanceApp.java:32
ClassCampaignPerformanceApp
topology-test/src/main/java/guru/learningjournal/kafka/examples/CampaignPerformanceApp.java:30
ClassCampaignPerformanceSerde
ad-campaigns/src/main/java/guru/learningjournal/kafka/examples/common/AppSerdes.java:37
ClassCampaignPerformanceSerde
topology-test/src/main/java/guru/learningjournal/kafka/examples/common/AppSerdes.java:37
ClassClicksByNewsType
top3-inventories/src/main/java/guru/learningjournal/kafka/examples/types/ClicksByNewsType.java:9
ClassClicksByNewsTypeSerde
top3-inventories/src/main/java/guru/learningjournal/kafka/examples/common/AppSerdes.java:70
ClassCountingSessionApp
counting-session/src/main/java/guru/learningjournal/kafka/examples/CountingSessionApp.java:37
ClassCountingWindowApp
Demo application for Windowed Aggregates @author prashant @author www.learningjournal.guru
counting-window/src/main/java/guru/learningjournal/kafka/examples/CountingWindowApp.java:42
ClassCustomSinkApp
Demo application for integrating Processor API with DSL @author prashant @author www.learningjournal.guru
custom-sink/src/main/java/guru/learningjournal/kafka/examples/CustomSinkApp.java:35
ClassDeliveryAddress
rewards-in-memory/src/main/java/guru/learningjournal/kafka/examples/types/DeliveryAddress.java:9
ClassDeliveryAddress
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/types/DeliveryAddress.java:10
ClassDeliveryAddress
time-check/src/main/java/guru/learningjournal/kafka/examples/types/DeliveryAddress.java:9
ClassDeliveryAddress
rewards-table/src/main/java/guru/learningjournal/kafka/examples/types/DeliveryAddress.java:9
ClassDeliveryAddress
pos-simulator/src/main/java/guru/learningjournal/kafka/examples/types/DeliveryAddress.java:9
ClassDeliveryAddress
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/DeliveryAddress.java:10
ClassDeliveryAddress
pos-fanout/src/main/java/guru/learningjournal/kafka/examples/types/DeliveryAddress.java:9
ClassDepartmentAggSerde
ktable-aggregate-query/src/main/java/guru/learningjournal/kafka/examples/AppSerdes.java:52
ClassDepartmentAggSerde
kstream-aggregate/src/main/java/guru/learningjournal/kafka/examples/AppSerdes.java:52
ClassDepartmentAggSerde
ktable-aggregate/src/main/java/guru/learningjournal/kafka/examples/AppSerdes.java:52
ClassDepartmentAggregate
ktable-aggregate-query/src/main/java/guru/learningjournal/kafka/examples/types/DepartmentAggregate.java:9
ClassDepartmentAggregate
kstream-aggregate/src/main/java/guru/learningjournal/kafka/examples/types/DepartmentAggregate.java:9
ClassDepartmentAggregate
ktable-aggregate/src/main/java/guru/learningjournal/kafka/examples/types/DepartmentAggregate.java:9
ClassDispatcher
Runnable Kafka message dispatcher @author prashant @author www.learningjournal.guru
producer-threads/src/main/java/guru/learningjournal/kafka/examples/Dispatcher.java:32
ClassDispatcher
transactional-producer/src/main/java/guru/learningjournal/kafka/examples/Dispatcher.java:26
ClassDispatcher
Runnable class send a batch of Json messages to Kafka Producer @author prashant @author www.learningjournal.guru
json-producer/src/main/java/guru/learningjournal/kafka/examples/Dispatcher.java:32
ClassDispatcher
A runnable class to dispatch a set of messages to Kafka producer
avro-producer/src/main/java/guru/learningjournal/kafka/examples/Dispatcher.java:28
ClassDispatcherDemo
Kafka producer to send events from a file. You can start one thread for each file @author prashant @author www.learningjournal.guru
producer-threads/src/main/java/guru/learningjournal/kafka/examples/DispatcherDemo.java:37
ClassEmployee
ktable-aggregate-query/src/main/java/guru/learningjournal/kafka/examples/types/Employee.java:9
ClassEmployee
kstream-aggregate/src/main/java/guru/learningjournal/kafka/examples/types/Employee.java:9
ClassEmployee
ktable-aggregate/src/main/java/guru/learningjournal/kafka/examples/types/Employee.java:9
ClassEmployeeSerde
ktable-aggregate-query/src/main/java/guru/learningjournal/kafka/examples/AppSerdes.java:36
ClassEmployeeSerde
kstream-aggregate/src/main/java/guru/learningjournal/kafka/examples/AppSerdes.java:36
ClassEmployeeSerde
ktable-aggregate/src/main/java/guru/learningjournal/kafka/examples/AppSerdes.java:36
ClassFanOutConfigs
Configurations for the PosFanOutApp @author prashant @author www.learningjournal.guru
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/FanOutConfigs.java:25
next →1–100 of 246, ranked by callers