import BaseProvider from '../core/BaseProvider';
export default class KafkaProvider extends BaseProvider {
    connectDataSource(): void;
}