import * as KafkaJS from 'kafkajs';
import { Consumer } from '../Consumer';
/**
 * Unmarshalls the message value and emit an enriched message event
 *
 * @param payload Kafka message
 * @param consumer Orchestrate Consumer
 */
export declare function onMessageReceived(payload: KafkaJS.EachMessagePayload, consumer: Consumer): void;