[jira] [Commented] (KAFKA-2565) Offset Commit is not working if multiple consumers try to commit the offset

2015-10-12 Thread Sreenivasulu Nallapati (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14952795#comment-14952795 ] Sreenivasulu Nallapati commented on KAFKA-2565: --- This happens basicall

Offset Commit is not working if multiple consumers try to commit the offset

2015-09-22 Thread Sreenivasulu Nallapati
Hello, We are seeing some strange behaviour with commitOffsets() method of kafka.javaapi.consumer.ConsumerConnector. We committing the offsets to zookeeper at the end of the consumer batch. We are running multiple consumers for the same topic. Test details: 1. Created a topic with three partition

[jira] [Commented] (KAFKA-2565) Offset Commit is not working if multiple consumers try to commit the offset

2015-09-22 Thread Sreenivasulu Nallapati (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14902366#comment-14902366 ] Sreenivasulu Nallapati commented on KAFKA-2565: --- Earliest Offset after

[jira] [Created] (KAFKA-2565) Offset Commit is not working if multiple consumers try to commit the offset

2015-09-22 Thread Sreenivasulu Nallapati (JIRA)
Sreenivasulu Nallapati created KAFKA-2565: - Summary: Offset Commit is not working if multiple consumers try to commit the offset Key: KAFKA-2565 URL: https://issues.apache.org/jira/browse/KAFKA-2565

Question regarding topic creation

2014-10-03 Thread Sreenivasulu Nallapati
Hello, I am new to Kafka and trying to evaluate for one of our use case. I have a basic question regarding topic. Assume we have a 10 broker cluster. If a create a Topic, will it be created in all 10 brokers? If not, how it manages internally if we try to send a message to that perticular topic?

How producer gets the acknowledgement back

2014-09-24 Thread Sreenivasulu Nallapati
Hello, Can you please help me to get the acknowledgement in producer? After setting the property *request.required.acks to 1, *how producer gets the acknowledgement back? I am trying to get the acknowledgement in java producer. Thanks Sreeni