tomstepp commented on PR #33596:
URL: https://github.com/apache/beam/pull/33596#issuecomment-2620127696
@scwhittle if you have any tips, or know who we can ask:
```
WARNING: Configuration class
'org.apache.beam.sdk.io.kafka.KafkaIO$Read$External$Configuration' has no
schema registered. Attempting to construct with setter approach.
Expansion result: error: "java.lang.RuntimeException: Failed to build
transform from spec urn:
\"beam:transform:org.apache.beam:kafka_read_with_metadata:v1\"\npayload:
\"\\n\\212\\003\\n\\020\\n\\006topics\\032\\006\\032\\004\\n\\002\\020\\a\\n!\\n\\017consumer_config\\032\\n*\\b\\n\\002\\020\\a\\022\\002\\020\\a
\\001(\\001\\n\\032\\n\\020key_deserializer\\032\\002\\020\\a
\\002(\\002\\n\\034\\n\\022value_deserializer\\032\\002\\020\\a
\\003(\\003\\n\\031\\n\\017start_read_time\\032\\002\\020\\004
\\004(\\004\\n#\\n\\031commit_offset_in_finalize\\032\\002\\020\\b
\\005(\\005\\n\\032\\n\\020timestamp_policy\\032\\002\\020\\a
\\006(\\006\\n\\\"\\n\\030consumer_polling_timeout\\032\\002\\020\\004
\\a(\\a\\n\\037\\n\\025redistribute_num_keys\\032\\002\\020\\003
\\b(\\b\\n\\026\\n\\fredistribute\\032\\002\\020\\b
\\t(\\t\\n\\032\\n\\020allow_duplicates\\032\\002\\020\\b
\\n(\\n\\n\\036\\n\\024offset_deduplication\\032\\002\\020\\b
\\v(\\v\\022$059ad81c-549f-4ab3-adb7-37134f22938e\\022
\\372\\002\\f\\000\\000\\000\\000\\002\\006
...
worker.org.gradle.process.internal.worker.GradleWorkerMain.main(GradleWorkerMain.java:74)\nCaused
by: java.lang.IllegalStateException: Missing required properties:
offsetDeduplication\n\tat
org.apache.beam.sdk.io.kafka.AutoValue_KafkaIO_Read$Builder.build(AutoValue_KafkaIO_Read.java:627)\n\tat
org.apache.beam.sdk.io.kafka.KafkaIO$RowsWithMetadata$Builder.buildExternal(KafkaIO.java:2139)\n\tat
org.apache.beam.sdk.io.kafka.KafkaIO$RowsWithMetadata$Builder.buildExternal(KafkaIO.java:2113)\n\tat
org.apache.beam.sdk.expansion.service.ExpansionService$TransformProviderForBuilder.getTransform(ExpansionService.java:335)\n\t...
47 more\n"
Expected: a collection containing a string matching the pattern
'.*KafkaIO-Read.*'
but: was empty
```
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
