Closed bysph closed 9 months ago
add version param in kafka sink to adapt to old kafka version
@mustafaakin Could you please spare some time to review my code? thx~
add version param in kafka sink to adapt to old kafka version