apache / incubator-wayang / b4f375341470b85d398a3051b096fc2db5f2a6bd / . / wayang-plugins / wayang-hackit / wayang-hackit-shipper / wayang-hackit-shipper-kafka / src / test / java / org / apache / wayang / hackit / shipper / kafka / receiver