ennox108 opened a new issue, #9384: URL: https://github.com/apache/hudi/issues/9384
I am trying to add the Hudi Sink Connector to AWS MSK using the below config connector.class=org.apache.hudi.connect.HoodieSinkConnector s3.region=us-east-1 hoodie.base.path=s3://data_bucket/ hoodie.table.type=MERGE_ON_READ flush.size=5 tasks.max=4 topics=****** hoodie.schemaprovider.class=org.apache.hudi.schema.SchemaRegistryProvider bootstrap.servers=******************** hoodie.datasource.write.partitionpath.field=**** value.converter.region=us-east-1 hoodie.kafka.commit.interval.secs=60 hoodie.table.name=hudi-test hoodie.datasource.write.recordkey.field=***** value.converter.schemas.enable=false value.converter=org.apache.kafka.connect.json.JsonConverter key.converter=org.apache.kafka.connect.storage.StringConverter The logs show the error message "TransactionParticipant should be created for each assigned partition but has not been created for the topic/partition: " error. I have tried using all versions of Hudi and its the same issue every time. Under what condition would a TransactionParticipant be not created? -- 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]
