package kafka; | |
import org.junit.Test; | |
import java.util.HashMap; | |
import java.util.Map; | |
public class GeodeKafkaSourceTest { | |
@Test | |
public void durableClientIdShouldNotBeSetIfPropertyIsNotSet() { | |
GeodeKafkaSource source = new GeodeKafkaSource(); | |
Map<String, String> props = new HashMap<>(); | |
source.start(props); | |
} | |
@Test | |
public void cqPrefixShouldBeProperlyCalculatedFromProps() { | |
} | |
} |