replaced in line conditional with if else for backward compatibility
Update Kafka SI extensions to M2