MCPcopy Create free account

hub / github.com/SciSpike/kafka-lab / types & classes

Types & classes15 in github.com/SciSpike/kafka-lab

⨍ Functions 43◇ Types & classes 15
ClassConsumer
labs/02-Publish-And-Subscribe/consumer/src/main/java/app/Consumer.java:14
ClassDeviceMonitor
labs/04-Implement-Topics-And-Partitions/device-monitor/src/main/java/app/DeviceMonitor.java:14
ClassDeviceSimulator
labs/04-Implement-Topics-And-Partitions/device-simulator/src/main/java/app/DeviceSimulator.java:13
ClassDeviceSimulatorApp
labs/04-Implement-Topics-And-Partitions/device-simulator/src/main/java/app/DeviceSimulatorApp.java:14
ClassGpsDeviceSimulator
labs/06-Streaming/iot-kafka/gps-pump/src/main/java/app/GpsDeviceSimulator.java:13
ClassGpsDeviceSimulatorApp
labs/06-Streaming/iot-kafka/gps-pump/src/main/java/app/GpsDeviceSimulatorApp.java:12
ClassGpsMonitor
labs/06-Streaming/iot-kafka/gps-monitor/src/main/java/app/GpsMonitor.java:17
ClassHeartbeatMonitor
The heartbeat monitor from the Chapter 3 "implement topics & partitions" lab, re-implemented in Kafka Streams. <p>The plain-Java {@code device-monito
labs/06-Streaming/heartbeat-streams/src/main/java/app/HeartbeatMonitor.java:40
ClassHeartbeatProcessor
labs/06-Streaming/heartbeat-streams/src/main/java/app/HeartbeatMonitor.java:82
ClassLocationKey
labs/06-Streaming/iot-kafka/gps-monitor/src/main/java/app/LocationKey.java:5
ClassProducer
labs/02-Publish-And-Subscribe/producer/src/main/java/app/Producer.java:11
ClassSlowConsumer
A deliberately slow consumer used to demonstrate the {@code max.poll.interval.ms} eviction. <p>It "processes" each record by sleeping for {@code proc
labs/classroom/A4-Slow-Poll-Eviction/slow-consumer/src/main/java/app/SlowConsumer.java:34
ClassStreamExample
labs/06-Streaming/wordcount-kafka-streaming/src/main/java/app/StreamExample.java:17
ClassTuple
labs/04-Implement-Topics-And-Partitions/device-monitor/src/main/java/app/DeviceMonitor.java:127
ClassTxnProducer
A transactional producer used to demonstrate Kafka's exactly-once delivery. <p>It writes a batch of records inside a single Kafka <b>transaction</b>,
labs/classroom/A5-Exactly-Once/txn-producer/src/main/java/app/TxnProducer.java:27