No generic in JStreamParallelStreamProcessor factory method

[acktsap]

parallel-consumer/parallel-consumer-core/src/main/java/io/confluent/parallelconsumer/JStreamParallelStreamProcessor.java

Lines 17 to 19 in 540b0b9

	static JStreamParallelStreamProcessor createJStreamEosStreamProcessor(ParallelConsumerOptions<?, ?> options) {
	return new JStreamParallelEoSStreamProcessor<>(options);
	}

It looks removed in #223. It is intended?

[astubbs]

Hi! You’re the first person to ever ask about this interface :)
Aside from your question, may I know why this interface is your preference?
I’ll take a look soon.

[acktsap]

Thanks for reply!

Actually i don't use it. I just think it would be better to keep consistency with ParallelStreamProcessor.

parallel-consumer/parallel-consumer-core/src/main/java/io/confluent/parallelconsumer/ParallelStreamProcessor.java

Lines 25 to 27 in 540b0b9

	static <KK, VV> ParallelStreamProcessor<KK, VV> createEosStreamProcessor(ParallelConsumerOptions<KK, VV> options) {
	return new ParallelEoSStreamProcessor(options);
	}

[astubbs]

Yes, def. I'll fix it. But I'm also thinking about removing the Stream interfaces.