《KAFKA STREAMS IN ACTION》part 3

Part 3 Administering Kafka Streams

7. Monitoring and performance

1. Basic Kafka monitoring

Measuring consumer and producer performance
Checking for consumer lag

Intercepting the producer and consumer

Although interceptors aren’t typically your first line for debugging, they can prove useful in observing the behavior of your Kafka streaming application, and they’re a valuable addition to your toolbox.

2. Application metrics

3. More Kafka Streams debugging techniques

Using the StateListener
State restore listener

8. Testing a Kafka Streams application

1. Testing a topology

ProcessorTopologyTestDriver

The critical point to keep in mind with this test is that you now have a
repeatable test running a record through your entire topology, without the overhead of running Kafka.

2. Integration testing

Integration tests with the EmbeddedKafkaCluster should be used sparingly, and only when you have interactive behavior that can only be verified with a live,running Kafka broker.




Leave a Reply