Basic test for demonstration of working with the {@link org.apache.kafka.clients.admin.KafkaAdminClient}

User: Bill Bejeck Date: 10/6/20 Time: 9:25 PM

User: Bill Bejeck Date: 10/3/20 Time: 3:03 PM

User: Bill Bejeck Date: 10/5/20 Time: 9:48 AM

User: Bill Bejeck Date: 10/6/20 Time: 9:37 PM

User: Bill Bejeck Date: 10/3/20 Time: 3:21 PM

User: Bill Bejeck Date: 10/5/20 Time: 9:43 AM

Test for demo of using producer and consumer with Avro schemas

Demo of the ReflectionAvroSerializer and ReflectionAvroDeserializer that makes use of the Avro Reflection API https://avro.apache.org/docs/current/a

User: Bill Bejeck Date: 10/5/20 Time: 8:57 AM

User: Bill Bejeck Date: 10/5/20 Time: 8:57 AM

User: Bill Bejeck Date: 10/5/20 Time: 8:57 AM

Base Kafka container for re-use across tests

User: Bill Bejeck Date: 10/4/20 Time: 6:16 PM

User: Bill Bejeck Date: 10/4/20 Time: 6:16 PM

User: Bill Bejeck Date: 10/4/20 Time: 6:16 PM

Base Kafka container for re-use across tests This class makes use of the Toxiproxy container for simulating network issues

User: Bill Bejeck Date: 7/17/21 Time: 4:13 PM

Base Kafka test container for re-use across tests. This Kafka container is configured for transactional API tests and sets correct Kafka configs for u

User: Bill Bejeck Date: 5/29/21 Time: 3:50 PM

KafkaListener handling the different completed loan applications

Utility class used for processing records in a separate thread as part of the pipelining example in chapter 4. Note that class is meant only to serve

A implementation of the {@link DataSource} interface that supplies the same three Avro events with each call to {@link DataSource#fetch()} useful for

An implementation of the {@link DataSource} interface that returns the same 3 Protobuf events with each call to {@link DataSource#fetch()} useful for

Interface used to inject record handling into various consumer clients throughout the examples

Client application as a simple example of a currency exchange application. This will serve as an example for testing Kafka Producer and Consumer clien

Consumer - produce application simulating an exchange service application. This was written to support writing tests for consumer and producer applica

Record class to represent a currency transaction

An example of using a KafkaClientSupplier to provide a Kafka Streams application your own KafkaProducer and KafkaConsumer instances

User: Bill Bejeck Date: 2/17/22 Time: 9:31 PM

Basic Java POJO for JsonSchema examples

Utility class that provides various methods for generating data used in examples throughout the book

Interface for providing a data source for examples

User: Bill Bejeck Date: 1/24/22 Time: 8:21 PM

TopicNameExtractor that chooses the topic name at dynamically based on the value contained in the "routing" header

Test showing how the {@link KafkaProducer} in idempotent mode works. The test class makes use of the {@link ToxiproxyContainer} to simulate network pa

Aggregation object for Iot sensor windowing examples

Basic Aggregator instance

Simple implementation of a stand alone {@link Deserializer}

Test for demo of using producer and consumer with JSONSchema schemas

Example of using schema references with Json Schema. In this example the College schema has a reference to the Person schema

Example of using Schema Registry and Json Schema with references

Simple implementation of a stand alone {@link Serializer}

An example of a KTable aggregation operation

Example of a basic count operation with a KTable

Example of a filter operation with a KTable

Demonstration of KTable-KTable Foreign Key join The RetailPurchase is keyed by customer-id but contains the foreign key of employee-id and the employe

User: Bill Bejeck Date: 10/11/22 Time: 6:23 PM

User: Bill Bejeck Date: 11/12/22 Time: 2:27 PM

User: Bill Bejeck Date: 10/11/22 Time: 6:23 PM

Example demonstrating the {@link KStream#join(KStream, ValueJoiner, JoinWindows, StreamJoined)} method

Initial Kafka Streams application that "yells" at people, it's a great app to run it relieves stress.

The Yelling Kafka Streams application using the peek operator to display records to the console

The Kafka Streams Yelling application with named processors look at the topology description to see how it's more descriptive

User: Bill Bejeck Date: 11/5/22 Time: 12:00 PM

User: Bill Bejeck Date: 10/12/22 Time: 2:02 PM