[ https://issues.apache.org/jira/browse/BEAM-7942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Alexey Romanenko closed BEAM-7942. ---------------------------------- Fix Version/s: (was: 2.8.0) Not applicable Assignee: Alexey Romanenko Resolution: Won't Fix It was fixed on user side. > Kafka backward compatibility > ----------------------------- > > Key: BEAM-7942 > URL: https://issues.apache.org/jira/browse/BEAM-7942 > Project: Beam > Issue Type: Improvement > Components: io-java-kafka > Affects Versions: 2.13.0 > Reporter: Reenu Saluja > Assignee: Alexey Romanenko > Priority: Major > Fix For: Not applicable > > > getting below error using kafka 1.0 with Beam 2.13.0 > Uncaught throwable from user code: java.lang.IllegalStateException: No > TransformEvaluator registered for BOUNDED transform Read(CreateSource) > at > org.apache.beam.vendor.guava.v20_0.com.google.common.base.Preconditions.checkState(Preconditions.java:518) > So I had to downgrade beam version to 2.8.0 to work it. -- This message was sent by Atlassian Jira (v8.3.4#803005)