File Data Consumer

Kamanja has a utility called file data consumer that allows users to populate Kafka message queues from files. This tool works as follows: An administrator sets up a directory that is accessible to the tool (the tool must have read/write permissions for this new directory). The file data consumer monitors this directory and detects when … Read More

Time Partitioning

A message definition supports time partition as an optional key. The attributes under the time partition key are Key, Format and Type. Key – should be one of the fields from the message definition. Format – The format of the data in the input message. The value of the format in the message definition can … Read More