New to Chronicle Queue.

[Kidong Lee]

Hi,

I am new to chronicle queue. I have just played chronicle queue 4.5.15.

I have some questions:

1. when the process is restarted, the messages can be read from the offset before which the process have already read messages before. If so, is there any offset-commit option in chronicle queue like kafka consumer?

2. chronicle queue can be used as pub/sub pattern in a process?, for instance:
  
    (Message Validation) ------> (Chronicle Queue) ----------> (Producing Messages to Kafka) 
                                                         |
                                                         |
                                                        + ----------------------> (Logging Messages)
   
   In my processor, the incoming user behavior event messages are validated first, after that, the validated messages are published to disruptor queue, from which the same messages are consumed by both logging task and kafka producer task.
   I am considering replacing my disruptor queue with chronicle queue like above diagram.


thanks,

- Kidong Lee.

[Peter Lawrey]

Hello?

You can wind to any message index on a restart. Typically you store the index you read up to. Eg with an output queue. If you read my blog Vanilla Java you can see examples of how to do this automatically.

Chronicle Queue can be used for low latency distribution between threads/processes, pub/sub, as well as logging every message.

Regards, Peter.

--
You received this message because you are subscribed to the Google Groups "Chronicle" group.
To unsubscribe from this group and stop receiving emails from it, send an email to java-chronicle+unsubscribe@googlegroups.com.
For more options, visit https://groups.google.com/d/optout.

[Kidong Lee]

thanks for your reply, Peter.

I have read some of your blog, but I have not found the example of winding to the message index on restart automatically.

Could you give me a link to that?

regards,

- Kidong.

[Peter Lawrey]

Hello,
   This is the article where I cover automatic handling of restart.

https://vanilla-java.github.io/2016/03/29/Microservices-in-the-Chronicle-world-Part-4.html

You can handle yourself by obtaining or setting the index of the Tailer.

Regards, Peter.

[Kidong Lee]

Thank you, Peter.

- Kidong

2016년 10월 16일 일요일, Peter Lawrey<peter....@gmail.com>님이 작성한 메시지:

You received this message because you are subscribed to a topic in the Google Groups "Chronicle" group.
To unsubscribe from this topic, visit https://groups.google.com/d/topic/java-chronicle/os1o6wY6nfU/unsubscribe.
To unsubscribe from this group and all its topics, send an email to java-chronicle+unsubscribe@googlegroups.com.