DefaultPartitioner & FieldPartitioner don't work

We use confluent 5.5.0 to transform data from kafka to s3.
Before we use the TimeBasedPartitioner, it works fine.
now we add a new connect job to use FieldPartitioner with
it doesn’t work with any error log. it will not consume data from kafka(since the consumer group id is not generated in kafka).
i update FieldPartitioner to TimeBasedPartitioner, it works. Also i test the DefaultPartitioner(based on kafka topic’s partition), it doesn’t work too.

This topic was automatically closed 30 days after the last reply. New replies are no longer allowed.