@Test public void getKind() { assertEquals(MRecordSource.Kind.INFINITE, source.getKind()); }
@Override public Kind getKind() { return Kind.INFINITE; }
KafkaMRecordSource implements MRecordSource { @Override public Kind getKind() { return Kind.INFINITE; } }
KafkaMRecordSource implements MRecordSource { @Override public Kind getKind() { return Kind.INFINITE; } KafkaMRecordSource(KafkaConsumer<String, UntypedValues> consumer); @SuppressWarnings("squid:S2095") // KafkaConsumer is responsible for the closing of the Deserializers  KafkaMRecordSource(String kafkaUrl, String kafkaGroup, Collection<String> topics); @SuppressWarnings("squid:S2095") // KafkaConsumer is responsible for the closing of the Deserializers  KafkaMRecordSource(String kafkaUrl, String kafkaGroup, Collection<String> topics, boolean fromBeginning);  KafkaMRecordSource(String kafkaUrl, String kafkaGroup, Collection<String> topics,
                              Map<String, Object> additionalProperties); }
KafkaMRecordSource implements MRecordSource { @Override public Kind getKind() { return Kind.INFINITE; } KafkaMRecordSource(KafkaConsumer<String, UntypedValues> consumer); @SuppressWarnings("squid:S2095") // KafkaConsumer is responsible for the closing of the Deserializers  KafkaMRecordSource(String kafkaUrl, String kafkaGroup, Collection<String> topics); @SuppressWarnings("squid:S2095") // KafkaConsumer is responsible for the closing of the Deserializers  KafkaMRecordSource(String kafkaUrl, String kafkaGroup, Collection<String> topics, boolean fromBeginning);  KafkaMRecordSource(String kafkaUrl, String kafkaGroup, Collection<String> topics,
                              Map<String, Object> additionalProperties); @Override UntypedValues get(); @Override boolean hasRemaining(); @Override void init(); @Override void close(); @Override Kind getKind(); }
KafkaMRecordSource implements MRecordSource { @Override public Kind getKind() { return Kind.INFINITE; } KafkaMRecordSource(KafkaConsumer<String, UntypedValues> consumer); @SuppressWarnings("squid:S2095") // KafkaConsumer is responsible for the closing of the Deserializers  KafkaMRecordSource(String kafkaUrl, String kafkaGroup, Collection<String> topics); @SuppressWarnings("squid:S2095") // KafkaConsumer is responsible for the closing of the Deserializers  KafkaMRecordSource(String kafkaUrl, String kafkaGroup, Collection<String> topics, boolean fromBeginning);  KafkaMRecordSource(String kafkaUrl, String kafkaGroup, Collection<String> topics,
                              Map<String, Object> additionalProperties); @Override UntypedValues get(); @Override boolean hasRemaining(); @Override void init(); @Override void close(); @Override Kind getKind();  }