Dai
Dai
> I created a pull request to help with this issue: #82 Thanks, manually adding the fix to v3.6.2 fixed the problem!
I have seen a similar problem: ``` partitions.forEach(p => { console.log(p); consumer.seek({ topic: topicName, partition: p, offset: 0 }) }) ``` Partitions were read using `admin.fetchOffsets`. I did not see...
I too tested `admin.resetOffsets` and to the same result. I could only get one single oldest message from one of the partitions (`partition id = 1`). I have verified that...
Also no matter if I use `earliest: true`, offset of partition 1 always get resetted to earliest. I can always fetch first message from partition 1. I'm using v2.0.1. PS:...
Definitely needed. The self-signed root cert from osixia/openldap was expired in some older versions. I found some of the error messages from SSL clients differ, and some are quite confusing....
Still no luck.
Same here, "file not found" for something related to EMR
S3 Sink Task - Parquet - Error: Java.lang.NoClassDefFoundError: com/google/common/base/Preconditions
I just hit the same position as @dude0001. Manually adding guava but still not working!
S3 Sink Task - Parquet - Error: Java.lang.NoClassDefFoundError: com/google/common/base/Preconditions
Problem solved. Add corresponding `guava` then enjoy. https://stackoverflow.com/questions/68698325/confluent-kafka-s3-sink-connector-throws-java-lang-noclassdeffounderror-com-go/68698326#68698326
Just found that the same template is working when deployed to AWS, just not working locally. Very strange. Does that have anything to do with the local server?