MINOR: Fix multiple org.apache.kafka.streams.KafkaStreams.StreamStateListener being instantiated

[original-brownbear]

There should only be a single org.apache.kafka.streams.KafkaStreams.StreamStateListener to ensure synchronization of operations on org.apache.kafka.streams.KafkaStreams.StreamStateListener#threadState.

[original-brownbear]

@ijuma @dguy ping :) Hope I understood you guys correctly and this is what you had in mind here: #2791 (comment) :)

[asfbot]

Refer to this link for build results (access rights to CI server needed):
https://builds.apache.org/job/kafka-pr-jdk7-scala2.10/2677/
Test FAILed (JDK 7 and Scala 2.10).

[asfbot]

Refer to this link for build results (access rights to CI server needed):
https://builds.apache.org/job/kafka-pr-jdk8-scala2.12/2677/
Test PASSed (JDK 8 and Scala 2.12).

[dguy]

thanks @original-brownbear - yes that is what i had in mind. Just one nit otherwise LGTM

[dguy]

nit: final

[asfbot]

Refer to this link for build results (access rights to CI server needed):
https://builds.apache.org/job/kafka-pr-jdk8-scala2.11/2681/
Test PASSed (JDK 8 and Scala 2.11).

[original-brownbear]

@dguy alright :) final added :)

[asfbot]

Refer to this link for build results (access rights to CI server needed):
https://builds.apache.org/job/kafka-pr-jdk8-scala2.11/2682/
Test PASSed (JDK 8 and Scala 2.11).

[asfbot]

Refer to this link for build results (access rights to CI server needed):
https://builds.apache.org/job/kafka-pr-jdk8-scala2.12/2678/
Test PASSed (JDK 8 and Scala 2.12).

[original-brownbear]

@dguy @ijuma hmm I wonder if this is related to this change, seems Scala 2.10 dead locked again in the streams ITs ... maybe there is some unexpected side-effect here? Looking into that.

[original-brownbear]

@dguy @ijuma hmm never mind the above, I can't reproduce locking in RegexSourceIntegrationTest locally and the KafkaStreamsTest is still fine (on the same machine that was easily able to reproduce the other deadlock).
=> different issue I guess

[asfbot]

Refer to this link for build results (access rights to CI server needed):
https://builds.apache.org/job/kafka-pr-jdk7-scala2.10/2678/
Test FAILed (JDK 7 and Scala 2.10).