cti-kafka-rest-event-interceptor

Library to intercept Apache Kafka messages for testing purposes

Usage

const eventInterceptor = require( 'cti-kafka-rest-event-interceptor' );
const KafkaRestEventPublisher = require( 'cti-kafka-rest-event-publisher' ).KafkaRestEventPublisher;

const options = {
    url: 'http://localhost',
    topic: 'interceptorTest',
    filter: {
        body: {
            message: 'Test message'
        }
    },
    response: {
    	code: 200,
        body: {
            data: 'Test data'
        }
    }
};

const event = {
    message: 'Test message'
};

const interceptedEvent = eventInterceptor.intercept( options );

const eventPublisher = new KafkaRestEventPublisher( options.url );
return eventPublisher.publish( context, options.topic, event )
    .then( res => {

        console.log( `Event was intercepted: ${ eventInterceptor.wasIntercepted( interceptedEvent ) }` );
       	console.log( res );
    } );