streamthoughts/kafka-connect-file-pulse

Issues

• Challenges with File Pulse Connector for Real-Time Log Streaming from Kubernetes: Meeting Requirements for Incremental Updates and Dynamic File Monitoring

  #661 opened 5 months ago by max533
  1

• AmazonS3MoveCleanupPolicy doesn't cleanup files during KafkaConnect workers restart

  #671 opened 3 months ago by arnitolog
  0

• Schema Registry & Amazon S3 Move Cleanup Policy Questions

  #584 opened a year ago by jwhitehead77
  1

• GroupRowFilter buffer not forwarded when empty line(s) at the end of the csv file

  #667 opened 3 months ago by Belbli
  0

• CSV file with DelimitedRowFilter filter with list of columns not working as expected

  #663 opened 4 months ago by polasanthoshkumar
  2

• Convert Record Timestamps into Avro Logical Date Type

  #665 opened 4 months ago by schrieveslaach
  1

• Get Node Name while processing XML with reader.xpath.expression

  #660 opened 5 months ago by jlgalvan-ts
  1

• CSV file, filter with list of columns

  #482 opened 2 years ago by ypynda
  10

• Do we have a configuration or workaround to bypass escape character while reading files using CSV filter

  #662 opened 4 months ago by utkarshnehete
  0

• Kafka File pulse running in infinite loop while processing s3 file

  #655 opened 5 months ago by ritesh-payu
  0

• Kafka Connect File Pulse Not Processing Updates in Existing Files

  #654 opened 5 months ago by goyaltu-deshaw
  1

• CSV Line to proper JSON

  #448 opened a year ago by srikanthvpai
  6

• Clarification on Topic Creation and Timeout Issue in Kafka Connect File Pulse Connector

  #653 opened 5 months ago by goyaltu-deshaw
  1

• NoSuchMethodError thrown when using GcsFileSystemListing

  #613 opened 9 months ago by tsironneau
  4

• AWS S3 Exception

  #630 opened 9 months ago by srikanthvpai
  1

• When using zipped file, is there any reason , why the zipped file is not removed from the directoty once unzipped?

  #603 opened 10 months ago by rouellet99
  12

• S3 source | CSV value.connect.schema alphabetical order

  #615 opened 9 months ago by Taha-AhmedK
  0

• Tilde Separator Issue

  #506 opened 10 months ago by Rocker64
  2

• Wrong mapping of field names to their index for DelimitedRowFilter

  #440 opened 2 years ago by loquisgon
  5

• How to build our own zip file from filepulse source ?

  #464 opened 10 months ago by srikanthvpai
  3

• How to extract one header row from multi header Csv and use as columns

  #466 opened 10 months ago by thutch
  3

• Off into space

  #472 opened 2 years ago by miramar-labs
  3

• Getting timeout exception for s3 source connector, has to do with tasks.file.status.storage.bootstrap.servers..

  #578 opened a year ago by agavili
  1

• skip metadata header

  #577 opened a year ago by Prosecutor22
  1

• FilePulse connector to parse log file with rotation policy.

  #485 opened 10 months ago by ypynda
  3

• Can not find kafka-connect-filepulse-api 2.12.0 on maven-central

  #488 opened 10 months ago by matthkoch
  6

• Error while Implementing DateFilter for CSV Source File with FilePulse Connector 2.12

  #489 opened 10 months ago by abjayon13
  2

• Would dynamic schema for CSV filter be something that would be good for the connector?

  #498 opened 10 months ago by kirito73
  2

• File pulse GCS to kafka

  #499 opened 10 months ago by izzie88
  6

• Confluent Hub Vulnerabilities

  #595 opened 10 months ago by ddonaghy-c
  0

• How can I get a log file in jsonl form?

  #594 opened a year ago by gurudykim
  0

• unable to use value.connect.schema in avro representation schema format

  #592 opened a year ago by tuxfight3r
  2

• Allow Special Character Handling

  #557 opened a year ago by e160842
  3

• LastModifiedFileFilter missing from 2.14.0-early-access

  #566 opened a year ago by pmizenin
  1

• FilePulse source connector 2.10 class could not be found

  #591 opened a year ago by Shykeng
  1

• is this connector dead?

  #476 opened a year ago by miramar-labs
  4

• SerializationException: Error registering Avro schema

  #500 opened a year ago by neeru-bhaskar
  2

• MalformedJsonException while Creating new Google Cloud Storage service using the the credentials JSON

  #582 opened a year ago by utkarshnehete
  1

• Support for AWS S3 server-side-encryption

  #507 opened a year ago by Aaronni03
  1

• Processing Hug files with JSON data takes hours together

  #509 opened a year ago by veeraraghukiranyerva
  2

• AzureBlobStorageFileSystemListing could not be found

  #523 opened a year ago by irux
  2

• Running csv example results in an error

  #511 opened a year ago by pmizenin
  1

• Invalid tracking file status taking as scheduled files are still processing

  #460 opened a year ago by iamsamba
  2

• Processing empty file goes infinite

  #457 opened a year ago by iamsamba
  2

• Does AmazonS3FileSystemListing support GZipped files?

  #444 opened a year ago by loquisgon
  4

• Feature request: send file metadata and process status to configurable topic

  #521 opened a year ago by dertin
  2

• DefaultFileSystemMonitor produces NPE during connector start

  #465 opened 2 years ago by madoed
  2

• Faster AWS S3 objects scanning

  #490 opened a year ago by bjarosze
  2

• java.lang.NoClassDefFoundError: Could not initialize class io.streamthoughts.kafka.connect.filepulse.expression.parser.ExpressionParsers

  #515 opened a year ago by PetrKramolis
  1

• How to turn CSV file into valid JSON

  #469 opened 2 years ago by RakhmedovRS
  1