[
https://issues.apache.org/jira/browse/BEAM-13526?focusedWorklogId=701451&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-701451
]
ASF GitHub Bot logged work on BEAM-13526:
-----------------------------------------
Author: ASF GitHub Bot
Created on: 28/Dec/21 09:28
Start Date: 28/Dec/21 09:28
Worklog Time Spent: 10m
Work Description: aromanenko-dev merged pull request #16339:
URL: https://github.com/apache/beam/pull/16339
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: github-unsubscr...@beam.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
Issue Time Tracking
-------------------
Worklog Id: (was: 701451)
Time Spent: 0.5h (was: 20m)
> Unable to use the KafkaIO.Read.withValueDeserializer(DeserializerProvider)
> method
> ---------------------------------------------------------------------------------
>
> Key: BEAM-13526
> URL: https://issues.apache.org/jira/browse/BEAM-13526
> Project: Beam
> Issue Type: Bug
> Components: io-java-kafka
> Affects Versions: 2.34.0
> Reporter: Arkadiusz Gasinski
> Priority: P2
> Time Spent: 0.5h
> Remaining Estimate: 0h
>
> I'm trying to configure my pipeline to read AVRO-encoded messages from Kafka
> with deserialization delegated to the
> ConfluentSchemaRegistryDeserialzerProvider, and I'm getting the following
> error:
> Exception in thread "main" java.lang.IllegalAccessError: failed to access
> class org.apache.beam.sdk.io.kafka.DeserializerProvider from class MyClass
> (both are in unnamed module of loader 'app')
> The way I configure the KafkaIO.Read is like:
> {code:java}
> KafkaIO.read<String, GenericRecord>()
> .withBootstrapServers(...)
> .withKeyDeserializer(StringDeserializer::class.java)
>
> .withValueDeserializer(ConfluentSchemaRegistryDeserializerProvider.of<GenericRecord>(...))
> .withTopic(...)
> ...{code}
> I checked the DeserializerProvider interface and it's package-private - it's
> not even listed in the official java docs for Beam
> ([https://beam.apache.org/releases/javadoc/2.34.0/org/apache/beam/sdk/io/kafka/package-summary.html]);
> the ConfluentSchemaRegistryDeserialzerProvider is public.
> Am I the only one trying to use this API, or am I doing sth terribly wrong?
>
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
