PLCyr commented on issue #1128: URL: https://github.com/apache/camel-kafka-connector/issues/1128#issuecomment-809569901
Sorry, I had misread "camel.source.endpoint.idempotent" for "camel.idempotency.enabled". Just tested "camel.source.endpoint.idempotent" to false and noop = true, same behavior The log still show a hint that Memory Idempotent Repo is used [2021-03-29 17:27:47,943] INFO Setting initial properties in Camel context: [[connector.class=org.apache.camel.kafkaconnector.sftp.CamelSftpSourceConnector, camel.source.endpoint.runLoggingLevel=INFO, camel.idempotency.enabled=true, transforms=RemoteTransformer, camel.idempotency.expression.header=CamelFileNameConsumed, camel.source.endpoint.download=false, camel.source.endpoint.noop=true, key.converter=org.apache.kafka.connect.storage.StringConverter, camel.source.contentLogLevel=INFO, transforms.RemoteTransformer.type=org.apache.camel.kafkaconnector.sftp.transformers.SftpRemoteFileTransforms, camel.source.endpoint.include=.*.txt, camel.source.endpoint.password=pass, name=sftp-connector, camel.source.path.directoryName=data/, camel.idempotency.kafka.topic=SFTP-Persistance-Topic, camel.source.endpoint.username=foo, camel.source.component=sftp, camel.source.path.host=sftp.sftp, camel.idempotency.repository.type=kafka, camel.idempotency.kafka.bootstrap.servers=confluent-kafka-cp-kaf ka:9092, value.converter=org.apache.kafka.connect.converters.ByteArrayConverter, camel.idempotency.expression.type=header, camel.source.endpoint.recursive=true, topics=SFTP-Topic, camel.source.path.port=22, camel.source.endpoint.idempotent=false, task.class=org.apache.camel.kafkaconnector.sftp.CamelSftpSourceTask, camel.source.endpoint.binary=false]] (org.apache.camel.kafkaconnector.utils.CamelKafkaConnectMain) [2021-03-29 17:27:47,944] INFO [Producer clientId=connector-producer-sftp-connector-0] Cluster ID: fFQtkPXrT92v270crRLidQ (org.apache.kafka.clients.Metadata) [2021-03-29 17:27:47,961] INFO Creating Camel route from(sftp:sftp.sftp:22/data/?binary=false&download=false&idempotent=false&include=.*.txt&noop=true&password=RAW(pass)&recursive=true&runLoggingLevel=INFO&username=RAW(foo)) (org.apache.camel.kafkaconnector.utils.CamelKafkaConnectMain) [2021-03-29 17:27:47,963] INFO idempotentConsumer(header(expressionHeader), MemoryIdempotentRepository.memoryIdempotentRepository(100)).to(direct:end?pollingConsumerQueueSize=1000&pollingConsumerBlockTimeout=0&pollingConsumerBlockWhenFull=true) (org.apache.camel.kafkaconnector.utils.CamelKafkaConnectMain) -- 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. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
