kafka-dev  

Messages by Thread

• • [jira] [Updated] (KAFKA-506) Store logical offset in log Jay Kreps (JIRA)
  • [jira] [Updated] (KAFKA-506) Store logical offset in log Jay Kreps (JIRA)
  • [jira] [Updated] (KAFKA-506) Store logical offset in log Jay Kreps (JIRA)
  • [jira] [Updated] (KAFKA-506) Store logical offset in log Jay Kreps (JIRA)
  • [jira] [Updated] (KAFKA-506) Store logical offset in log Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-506) Store logical offset in log Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-506) Store logical offset in log Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-506) Store logical offset in log Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-506) Store logical offset in log Jay Kreps (JIRA)
  • [jira] [Updated] (KAFKA-506) Store logical offset in log Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-506) Store logical offset in log Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-506) Store logical offset in log Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-506) Store logical offset in log Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-506) Store logical offset in log Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-506) Store logical offset in log Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-506) Store logical offset in log Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-506) Store logical offset in log Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-506) Store logical offset in log Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-506) Store logical offset in log Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-506) Store logical offset in log Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-506) Store logical offset in log Joel Koshy (JIRA)
  • [jira] [Commented] (KAFKA-506) Store logical offset in log Jay Kreps (JIRA)
  • [jira] [Updated] (KAFKA-506) Store logical offset in log Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-506) Store logical offset in log Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-506) Store logical offset in log Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-506) Store logical offset in log Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-506) Store logical offset in log Jun Rao (JIRA)
  • [jira] [Resolved] (KAFKA-506) Store logical offset in log Jay Kreps (JIRA)
  • Re: [jira] [Resolved] (KAFKA-506) Store logical offset in log Taylor Gautier
  • Re: [jira] [Resolved] (KAFKA-506) Store logical offset in log Jay Kreps
  • Re: [jira] [Resolved] (KAFKA-506) Store logical offset in log Taylor Gautier
  • [jira] [Commented] (KAFKA-506) Store logical offset in log Neha Narkhede (JIRA)
  • [jira] [Comment Edited] (KAFKA-506) Store logical offset in log Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-506) Store logical offset in log Jay Kreps (JIRA)
  • [jira] [Updated] (KAFKA-506) Store logical offset in log Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-506) Store logical offset in log Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-506) Store logical offset in log Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-506) Store logical offset in log Sam Meder (JIRA)
  • [jira] [Commented] (KAFKA-506) Store logical offset in log Jay Kreps (JIRA)
• [jira] [Work started] (KAFKA-325) revisit broker config in 0.8 Swapnil Ghike (JIRA)
• [jira] [Assigned] (KAFKA-325) revisit broker config in 0.8 Swapnil Ghike (JIRA)
• [jira] [Resolved] (KAFKA-455) ProducerSendThread calls ListBuffer.size a whole bunch. That is a O(n) operation Joel Koshy (JIRA)
• [jira] [Created] (KAFKA-505) Remove errorcode from TopicMetaDataResponse Swapnil Ghike (JIRA)
  • [jira] [Updated] (KAFKA-505) Remove errorcode from TopicMetaDataResponse Swapnil Ghike (JIRA)
  • [jira] [Commented] (KAFKA-505) Remove errorcode from TopicMetaDataResponse Swapnil Ghike (JIRA)
  • [jira] [Closed] (KAFKA-505) Remove errorcode from TopicMetaDataResponse Swapnil Ghike (JIRA)
  • [jira] [Resolved] (KAFKA-505) Remove errorcode from TopicMetaDataResponse Swapnil Ghike (JIRA)
• [jira] [Created] (KAFKA-504) UnsatisfiedLinkError causes snappy unit tests to fail on hudson server Jay Kreps (JIRA)
  • [jira] [Updated] (KAFKA-504) UnsatisfiedLinkError causes snappy unit tests to fail on hudson server Jay Kreps (JIRA)
  • [jira] [Updated] (KAFKA-504) UnsatisfiedLinkError causes snappy unit tests to fail on hudson server Jay Kreps (JIRA)
  • [jira] [Updated] (KAFKA-504) UnsatisfiedLinkError causes snappy unit tests to fail on hudson server Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-504) UnsatisfiedLinkError causes snappy unit tests to fail on hudson server Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-504) UnsatisfiedLinkError causes snappy unit tests to fail on hudson server Joe Stein (JIRA)
  • [jira] [Resolved] (KAFKA-504) UnsatisfiedLinkError causes snappy unit tests to fail on hudson server Jay Kreps (JIRA)
• [jira] [Created] (KAFKA-503) Support "testcase_to_run" or "testcase_to_skip" John Fung (JIRA)
  • [jira] [Assigned] (KAFKA-503) Support "testcase_to_run" or "testcase_to_skip" John Fung (JIRA)
  • [jira] [Updated] (KAFKA-503) Support "testcase_to_run" or "testcase_to_skip" Joel Koshy (JIRA)
  • [jira] [Resolved] (KAFKA-503) Support "testcase_to_run" or "testcase_to_skip" John Fung (JIRA)
• [jira] [Created] (KAFKA-502) Simplify setup / initialization in replication_basic_test.py John Fung (JIRA)
  • [jira] [Assigned] (KAFKA-502) Simplify setup / initialization in replication_basic_test.py John Fung (JIRA)
  • [jira] [Updated] (KAFKA-502) Simplify setup / initialization in replication_basic_test.py Joel Koshy (JIRA)
  • [jira] [Commented] (KAFKA-502) Simplify setup / initialization in replication_basic_test.py John Fung (JIRA)
  • [jira] [Updated] (KAFKA-502) Simplify setup / initialization in replication_basic_test.py John Fung (JIRA)
  • [jira] [Updated] (KAFKA-502) Simplify setup / initialization in replication_basic_test.py John Fung (JIRA)
  • [jira] [Comment Edited] (KAFKA-502) Simplify setup / initialization in replication_basic_test.py John Fung (JIRA)
  • [jira] [Updated] (KAFKA-502) Simplify setup / initialization in replication_basic_test.py John Fung (JIRA)
  • [jira] [Comment Edited] (KAFKA-502) Simplify setup / initialization in replication_basic_test.py John Fung (JIRA)
  • [jira] [Comment Edited] (KAFKA-502) Simplify setup / initialization in replication_basic_test.py John Fung (JIRA)
  • [jira] [Updated] (KAFKA-502) Simplify setup / initialization in replication_basic_test.py John Fung (JIRA)
  • [jira] [Commented] (KAFKA-502) Simplify setup / initialization in replication_basic_test.py Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-502) Simplify setup / initialization in replication_basic_test.py John Fung (JIRA)
  • [jira] [Commented] (KAFKA-502) Simplify setup / initialization in replication_basic_test.py Jun Rao (JIRA)
  • [jira] [Comment Edited] (KAFKA-502) Simplify setup / initialization in replication_basic_test.py Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-502) Simplify setup / initialization in replication_basic_test.py John Fung (JIRA)
  • [jira] [Commented] (KAFKA-502) Simplify setup / initialization in replication_basic_test.py John Fung (JIRA)
  • [jira] [Updated] (KAFKA-502) Simplify setup / initialization in replication_basic_test.py John Fung (JIRA)
  • [jira] [Commented] (KAFKA-502) Simplify setup / initialization in replication_basic_test.py John Fung (JIRA)
  • [jira] [Commented] (KAFKA-502) Simplify setup / initialization in replication_basic_test.py Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-502) Simplify setup / initialization in replication_basic_test.py John Fung (JIRA)
  • [jira] [Commented] (KAFKA-502) Simplify setup / initialization in replication_basic_test.py John Fung (JIRA)
  • [jira] [Comment Edited] (KAFKA-502) Simplify setup / initialization in replication_basic_test.py John Fung (JIRA)
  • [jira] [Updated] (KAFKA-502) Simplify setup / initialization in replication_basic_test.py John Fung (JIRA)
  • [jira] [Commented] (KAFKA-502) Simplify setup / initialization in replication_basic_test.py John Fung (JIRA)
  • [jira] [Updated] (KAFKA-502) Simplify setup / initialization in replication_basic_test.py John Fung (JIRA)
  • [jira] [Commented] (KAFKA-502) Simplify setup / initialization in replication_basic_test.py John Fung (JIRA)
  • [jira] [Commented] (KAFKA-502) Simplify setup / initialization in replication_basic_test.py Jay Kreps (JIRA)
  • [jira] [Updated] (KAFKA-502) Simplify setup / initialization in replication_basic_test.py John Fung (JIRA)
• Re: Build failed in Jenkins: Kafka-0.8 #36 Prashanth Menon
• [jira] [Created] (KAFKA-501) getOfffset Api needs to return different latest offset to regular and follower consumers Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-501) getOfffset Api needs to return different latest offset to regular and follower consumers Joel Koshy (JIRA)
  • [jira] [Assigned] (KAFKA-501) getOfffset Api needs to return different latest offset to regular and follower consumers Joel Koshy (JIRA)
  • [jira] [Updated] (KAFKA-501) getOfffset Api needs to return different latest offset to regular and follower consumers Joel Koshy (JIRA)
  • [jira] [Commented] (KAFKA-501) getOfffset Api needs to return different latest offset to regular and follower consumers Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-501) getOfffset Api needs to return different latest offset to regular and follower consumers Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-501) getOfffset Api needs to return different latest offset to regular and follower consumers Joel Koshy (JIRA)
  • [jira] [Resolved] (KAFKA-501) getOfffset Api needs to return different latest offset to regular and follower consumers Joel Koshy (JIRA)
  • [jira] [Closed] (KAFKA-501) getOfffset Api needs to return different latest offset to regular and follower consumers Joel Koshy (JIRA)
  • [jira] [Commented] (KAFKA-501) getOfffset Api needs to return different latest offset to regular and follower consumers Jun Rao (JIRA)
• [jira] [Created] (KAFKA-500) javaapi support for getTopoicMetaData Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-500) javaapi support for getTopoicMetaData Joel Koshy (JIRA)
  • [jira] [Assigned] (KAFKA-500) javaapi support for getTopoicMetaData Swapnil Ghike (JIRA)
  • [jira] [Updated] (KAFKA-500) javaapi support for getTopoicMetaData Swapnil Ghike (JIRA)
  • [jira] [Commented] (KAFKA-500) javaapi support for getTopoicMetaData Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-500) javaapi support for getTopoicMetaData Swapnil Ghike (JIRA)
  • [jira] [Commented] (KAFKA-500) javaapi support for getTopoicMetaData Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-500) javaapi support for getTopoicMetaData Swapnil Ghike (JIRA)
  • [jira] [Commented] (KAFKA-500) javaapi support for getTopoicMetaData Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-500) javaapi support for getTopoicMetaData Swapnil Ghike (JIRA)
  • [jira] [Comment Edited] (KAFKA-500) javaapi support for getTopoicMetaData Swapnil Ghike (JIRA)
  • [jira] [Commented] (KAFKA-500) javaapi support for getTopoicMetaData Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-500) javaapi support for getTopoicMetaData Swapnil Ghike (JIRA)
  • [jira] [Closed] (KAFKA-500) javaapi support for getTopoicMetaData Jun Rao (JIRA)
  • [jira] [Resolved] (KAFKA-500) javaapi support for getTopoicMetaData Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-500) javaapi support for getTopoicMetaData Sam Meder (JIRA)
  • [jira] [Commented] (KAFKA-500) javaapi support for getTopoicMetaData Sam Meder (JIRA)
  • [jira] [Updated] (KAFKA-500) javaapi support for getTopoicMetaData Sam Meder (JIRA)
  • [jira] [Updated] (KAFKA-500) javaapi support for getTopoicMetaData Sam Meder (JIRA)
• Question on SessionExpiredListener Bae, Jae Hyeon
• Apache Kafka C driver Magnus Edenhill
• [jira] [Created] (KAFKA-499) Refactor controller state machine Neha Narkhede (JIRA)
  • [jira] [Assigned] (KAFKA-499) Refactor controller state machine Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-499) Refactor controller state machine Joel Koshy (JIRA)
  • [jira] [Updated] (KAFKA-499) Refactor controller state machine Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-499) Refactor controller state machine Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-499) Refactor controller state machine Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-499) Refactor controller state machine Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-499) Refactor controller state machine Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-499) Refactor controller state machine Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-499) Refactor controller state machine Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-499) Refactor controller state machine Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-499) Refactor controller state machine Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-499) Refactor controller state machine Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-499) Refactor controller state machine Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-499) Refactor controller state machine Neha Narkhede (JIRA)
  • [jira] [Closed] (KAFKA-499) Refactor controller state machine Neha Narkhede (JIRA)
• [jira] [Created] (KAFKA-498) Controller code has race conditions and synchronization bugs Neha Narkhede (JIRA)
  • [jira] [Assigned] (KAFKA-498) Controller code has race conditions and synchronization bugs Neha Narkhede (JIRA)
  • [jira] [Work started] (KAFKA-498) Controller code has race conditions and synchronization bugs Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-498) Controller code has race conditions and synchronization bugs Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-498) Controller code has race conditions and synchronization bugs Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-498) Controller code has race conditions and synchronization bugs Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-498) Controller code has race conditions and synchronization bugs Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-498) Controller code has race conditions and synchronization bugs Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-498) Controller code has race conditions and synchronization bugs Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-498) Controller code has race conditions and synchronization bugs Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-498) Controller code has race conditions and synchronization bugs Joel Koshy (JIRA)
  • [jira] [Closed] (KAFKA-498) Controller code has race conditions and synchronization bugs Jun Rao (JIRA)
• [jira] [Created] (KAFKA-497) recover consumer during unclean leadership change Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-497) recover consumer during unclean leadership change Joel Koshy (JIRA)
  • [jira] [Resolved] (KAFKA-497) recover consumer during unclean leadership change Jun Rao (JIRA)
  • [jira] [Closed] (KAFKA-497) recover consumer during unclean leadership change Jun Rao (JIRA)
• [jira] [Created] (KAFKA-496) high level producer send should return a response Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-496) high level producer send should return a response Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-496) high level producer send should return a response Jay Kreps (JIRA)
  • [jira] [Updated] (KAFKA-496) high level producer send should return a response Joel Koshy (JIRA)
  • [jira] [Commented] (KAFKA-496) high level producer send should return a response Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-496) high level producer send should return a response Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-496) high level producer send should return a response Jun Rao (JIRA)
  • [jira] [Assigned] (KAFKA-496) high level producer send should return a response Jay Kreps (JIRA)
• [jira] [Commented] (KAFKA-347) change number of partitions of a topic online Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-347) change number of partitions of a topic online Jun Rao (JIRA)
• [jira] [Assigned] (KAFKA-340) ensure ISR has enough brokers during clean shutdown of a broker Joel Koshy (JIRA)
• [jira] [Updated] (KAFKA-482) Make producer to run for the entire duration of the System Test Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-482) Make producer to run for the entire duration of the System Test Joel Koshy (JIRA)
• MessageSet.getSerialized() Jay Kreps
  • Re: MessageSet.getSerialized() Jun Rao
  • Re: MessageSet.getSerialized() Jay Kreps
  • Re: MessageSet.getSerialized() Jun Rao
• [jira] [Closed] (KAFKA-285) Increase maximum value of log.retention.size Jun Rao (JIRA)
• [jira] [Closed] (KAFKA-246) log configuration values used Jun Rao (JIRA)
• [jira] [Updated] (KAFKA-246) log configuration values used Jun Rao (JIRA)
• [jira] [Updated] (KAFKA-325) revisit broker config in 0.8 Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-325) revisit broker config in 0.8 Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-325) revisit broker config in 0.8 Joel Koshy (JIRA)
  • [jira] [Updated] (KAFKA-325) revisit broker config in 0.8 Swapnil Ghike (JIRA)
  • [jira] [Updated] (KAFKA-325) revisit broker config in 0.8 Swapnil Ghike (JIRA)
  • [jira] [Updated] (KAFKA-325) revisit broker config in 0.8 Swapnil Ghike (JIRA)
• [jira] [Assigned] (KAFKA-203) Improve Kafka internal metrics Jun Rao (JIRA)
• [jira] [Created] (KAFKA-495) Handle topic names with "/" on Kafka server Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-495) Handle topic names with "/" on Kafka server Neha Narkhede (JIRA)
  • [jira] [Assigned] (KAFKA-495) Handle topic names with "/" on Kafka server Swapnil Ghike (JIRA)
  • [jira] [Work started] (KAFKA-495) Handle topic names with "/" on Kafka server Swapnil Ghike (JIRA)
  • [jira] [Updated] (KAFKA-495) Handle topic names with "/" on Kafka server Swapnil Ghike (JIRA)
  • [jira] [Updated] (KAFKA-495) Handle topic names with "/" on Kafka server Swapnil Ghike (JIRA)
  • [jira] [Commented] (KAFKA-495) Handle topic names with "/" on Kafka server Swapnil Ghike (JIRA)
  • [jira] [Commented] (KAFKA-495) Handle topic names with "/" on Kafka server Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-495) Handle topic names with "/" on Kafka server Jay Kreps (JIRA)
  • [jira] [Comment Edited] (KAFKA-495) Handle topic names with "/" on Kafka server Swapnil Ghike (JIRA)
  • [jira] [Commented] (KAFKA-495) Handle topic names with "/" on Kafka server Swapnil Ghike (JIRA)
  • [jira] [Comment Edited] (KAFKA-495) Handle topic names with "/" on Kafka server Swapnil Ghike (JIRA)
  • [jira] [Commented] (KAFKA-495) Handle topic names with "/" on Kafka server Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-495) Handle topic names with "/" on Kafka server Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-495) Handle topic names with "/" on Kafka server Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-495) Handle topic names with "/" on Kafka server Joel Koshy (JIRA)
  • [jira] [Updated] (KAFKA-495) Handle topic names with "/" on Kafka server Swapnil Ghike (JIRA)
  • [jira] [Commented] (KAFKA-495) Handle topic names with "/" on Kafka server Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-495) Handle topic names with "/" on Kafka server Swapnil Ghike (JIRA)
  • [jira] [Updated] (KAFKA-495) Handle topic names with "/" on Kafka server Swapnil Ghike (JIRA)
  • [jira] [Commented] (KAFKA-495) Handle topic names with "/" on Kafka server Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-495) Handle topic names with "/" on Kafka server Jun Rao (JIRA)

• Earlier messages
• Later messages