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 partition.field.name.
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.