kafka-dev  

Messages by Thread

• • Re: Log.getOffsetsBefore() Jay Kreps
  • Re: Log.getOffsetsBefore() Prashanth Menon
• Maven support Jay Kreps
• [jira] [Created] (KAFKA-520) ConsumerIterator implemented by KafkaStream doesn't follow Java practices Esko Suomi (JIRA)
• [jira] [Created] (KAFKA-519) Allow commiting the state of single KafkaStream Esko Suomi (JIRA)
• 0.7.2 release Joe Stein
  • Re: 0.7.2 release Jun Rao
  • Re: 0.7.2 release Lorenzo Alberton
  • Re: 0.7.2 release Jun Rao
  • Re: 0.7.2 release Lorenzo Alberton
  • Re: 0.7.2 release Magnus Edenhill
  • Re: 0.7.2 release Lorenzo Alberton
  • Re: 0.7.2 release Jun Rao
  • Re: 0.7.2 release Jun Rao
• [jira] [Resolved] (KAFKA-482) Make producer to run for the entire duration of the System Test John Fung (JIRA)
• [jira] [Commented] (KAFKA-344) migration tool from 0.7 to 0.8 Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-344) migration tool from 0.7 to 0.8 Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-344) migration tool from 0.7 to 0.8 Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-344) migration tool from 0.7 to 0.8 Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-344) migration tool from 0.7 to 0.8 Jay Kreps (JIRA)
• [jira] [Created] (KAFKA-518) Replace kafka.log.SegmentList with ConcurrentSkipListMap Jay Kreps (JIRA)
  • [jira] [Updated] (KAFKA-518) Replace kafka.log.SegmentList with ConcurrentSkipListMap Jay Kreps (JIRA)
• [jira] [Commented] (KAFKA-133) Publish kafka jar to a public maven repository Otis Gospodnetic (JIRA)
  • [jira] [Commented] (KAFKA-133) Publish kafka jar to a public maven repository Chris Aniszczyk (JIRA)
  • Re: [jira] [Commented] (KAFKA-133) Publish kafka jar to a public maven repository will martin
  • [jira] [Commented] (KAFKA-133) Publish kafka jar to a public maven repository Sam Meder (JIRA)
  • [jira] [Commented] (KAFKA-133) Publish kafka jar to a public maven repository Otis Gospodnetic (JIRA)
  • [jira] [Commented] (KAFKA-133) Publish kafka jar to a public maven repository Sam Meder (JIRA)
  • [jira] [Commented] (KAFKA-133) Publish kafka jar to a public maven repository Otis Gospodnetic (JIRA)
  • [jira] [Commented] (KAFKA-133) Publish kafka jar to a public maven repository Otis Gospodnetic (JIRA)
  • [jira] [Commented] (KAFKA-133) Publish kafka jar to a public maven repository Pierre-Yves Ritschard (JIRA)
  • [jira] [Commented] (KAFKA-133) Publish kafka jar to a public maven repository Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-133) Publish kafka jar to a public maven repository Otis Gospodnetic (JIRA)
  • [jira] [Commented] (KAFKA-133) Publish kafka jar to a public maven repository Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-133) Publish kafka jar to a public maven repository Otis Gospodnetic (JIRA)
  • [jira] [Commented] (KAFKA-133) Publish kafka jar to a public maven repository Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-133) Publish kafka jar to a public maven repository Otis Gospodnetic (JIRA)
  • [jira] [Commented] (KAFKA-133) Publish kafka jar to a public maven repository Jay Kreps (JIRA)
• [jira] [Resolved] (KAFKA-6) Support replicating from more than 1 remote kafka cluster Joel Koshy (JIRA)
• [jira] [Updated] (KAFKA-484) Move log settings in the beginning of system_test_runner.py to an external log properties file Joel Koshy (JIRA)
• [jira] [Updated] (KAFKA-485) Support MacOS for this test framework Joel Koshy (JIRA)
  • [jira] [Updated] (KAFKA-485) Support MacOS for this test framework Joel Koshy (JIRA)
  • [jira] [Updated] (KAFKA-485) Support MacOS for this test framework Joel Koshy (JIRA)
• [jira] [Updated] (KAFKA-488) Port Mirroring System Test to this python system test framework Joel Koshy (JIRA)
• [jira] [Created] (KAFKA-517) Ensure that we escape the metric names if they include user strings Jay Kreps (JIRA)
  • [jira] [Updated] (KAFKA-517) Ensure that we escape the metric names if they include user strings Joel Koshy (JIRA)
  • [jira] [Updated] (KAFKA-517) Ensure that we escape the metric names if they include user strings Joel Koshy (JIRA)
  • [jira] [Commented] (KAFKA-517) Ensure that we escape the metric names if they include user strings Yang Ye (JIRA)
  • [jira] [Resolved] (KAFKA-517) Ensure that we escape the metric names if they include user strings Yang Ye (JIRA)
  • [jira] [Reopened] (KAFKA-517) Ensure that we escape the metric names if they include user strings Joel Koshy (JIRA)
• [jira] [Created] (KAFKA-516) Consider catching all exceptions in ShutdownableThread Jay Kreps (JIRA)
  • [jira] [Updated] (KAFKA-516) Consider catching all exceptions in ShutdownableThread Joel Koshy (JIRA)
  • [jira] [Updated] (KAFKA-516) Consider catching all exceptions in ShutdownableThread Joel Koshy (JIRA)
  • [jira] [Commented] (KAFKA-516) Consider catching all exceptions in ShutdownableThread Yang Ye (JIRA)
  • [jira] [Resolved] (KAFKA-516) Consider catching all exceptions in ShutdownableThread Yang Ye (JIRA)
  • [jira] [Closed] (KAFKA-516) Consider catching all exceptions in ShutdownableThread Jun Rao (JIRA)
• [jira] [Created] (KAFKA-515) Log cleanup can close a file channel opnened by Log.read before the transfer completes Swapnil Ghike (JIRA)
  • [jira] [Commented] (KAFKA-515) Log cleanup can close a file channel opnened by Log.read before the transfer completes Jay Kreps (JIRA)
• [jira] [Created] (KAFKA-514) Replication with Leader Failure Test: Log segment files checksum mismatch John Fung (JIRA)
  • [jira] [Updated] (KAFKA-514) Replication with Leader Failure Test: Log segment files checksum mismatch Joel Koshy (JIRA)
  • [jira] [Updated] (KAFKA-514) Replication with Leader Failure Test: Log segment files checksum mismatch Joel Koshy (JIRA)
  • [jira] [Updated] (KAFKA-514) Replication with Leader Failure Test: Log segment files checksum mismatch John Fung (JIRA)
  • [jira] [Updated] (KAFKA-514) Replication with Leader Failure Test: Log segment files checksum mismatch John Fung (JIRA)
  • [jira] [Commented] (KAFKA-514) Replication with Leader Failure Test: Log segment files checksum mismatch John Fung (JIRA)
  • [jira] [Updated] (KAFKA-514) Replication with Leader Failure Test: Log segment files checksum mismatch John Fung (JIRA)
  • [jira] [Updated] (KAFKA-514) Replication with Leader Failure Test: Log segment files checksum mismatch John Fung (JIRA)
  • [jira] [Comment Edited] (KAFKA-514) Replication with Leader Failure Test: Log segment files checksum mismatch John Fung (JIRA)
  • [jira] [Updated] (KAFKA-514) Replication with Leader Failure Test: Log segment files checksum mismatch John Fung (JIRA)
  • [jira] [Commented] (KAFKA-514) Replication with Leader Failure Test: Log segment files checksum mismatch John Fung (JIRA)
  • [jira] [Updated] (KAFKA-514) Replication with Leader Failure Test: Log segment files checksum mismatch Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-514) Replication with Leader Failure Test: Log segment files checksum mismatch John Fung (JIRA)
  • [jira] [Updated] (KAFKA-514) Replication with Leader Failure Test: Log segment files checksum mismatch Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-514) Replication with Leader Failure Test: Log segment files checksum mismatch John Fung (JIRA)
• [jira] [Created] (KAFKA-513) Add state change log to Kafka brokers Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-513) Add state change log to Kafka brokers Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-513) Add state change log to Kafka brokers Joel Koshy (JIRA)
  • [jira] [Commented] (KAFKA-513) Add state change log to Kafka brokers Prashanth Menon (JIRA)
  • [jira] [Commented] (KAFKA-513) Add state change log to Kafka brokers Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-513) Add state change log to Kafka brokers Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-513) Add state change log to Kafka brokers Prashanth Menon (JIRA)
  • [jira] [Commented] (KAFKA-513) Add state change log to Kafka brokers Prashanth Menon (JIRA)
  • [jira] [Commented] (KAFKA-513) Add state change log to Kafka brokers Joel Koshy (JIRA)
  • [jira] [Commented] (KAFKA-513) Add state change log to Kafka brokers Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-513) Add state change log to Kafka brokers Prashanth Menon (JIRA)
  • [jira] [Commented] (KAFKA-513) Add state change log to Kafka brokers Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-513) Add state change log to Kafka brokers Swapnil Ghike (JIRA)
  • [jira] [Commented] (KAFKA-513) Add state change log to Kafka brokers Prashanth Menon (JIRA)
  • [jira] [Assigned] (KAFKA-513) Add state change log to Kafka brokers Swapnil Ghike (JIRA)
  • [jira] [Commented] (KAFKA-513) Add state change log to Kafka brokers Swapnil Ghike (JIRA)
  • [jira] [Commented] (KAFKA-513) Add state change log to Kafka brokers Neha Narkhede (JIRA)
• Re: InvalidMessageException vs InvalidMessageSizeException vs MessageSizeTooLargeException Jun Rao
  • Re: InvalidMessageException vs InvalidMessageSizeException vs MessageSizeTooLargeException Jay Kreps
• [jira] [Created] (KAFKA-512) Remove checksum from ByteBufferMessageSet Jay Kreps (JIRA)
  • [jira] [Updated] (KAFKA-512) Remove checksum from ByteBufferMessageSet.iterator Jay Kreps (JIRA)
  • [jira] [Updated] (KAFKA-512) Remove checksum from ByteBufferMessageSet.iterator Jun Rao (JIRA)
  • [jira] [Closed] (KAFKA-512) Remove checksum from ByteBufferMessageSet.iterator Jun Rao (JIRA)
  • [jira] [Resolved] (KAFKA-512) Remove checksum from ByteBufferMessageSet.iterator Jun Rao (JIRA)
• Broker computes message crcs twice Jay Kreps
  • Re: Broker computes message crcs twice Jay Kreps
  • Re: Broker computes message crcs twice Jay Kreps
  • Re: Broker computes message crcs twice Jun Rao
• [jira] [Closed] (KAFKA-325) revisit broker config in 0.8 Jun Rao (JIRA)
• [jira] [Resolved] (KAFKA-325) revisit broker config in 0.8 Jun Rao (JIRA)
• Coding convention: tuples vs case classes Joel Koshy
  • Re: Coding convention: tuples vs case classes Jakob Homan
  • Re: Coding convention: tuples vs case classes Joe Stein
  • Re: Coding convention: tuples vs case classes Neha Narkhede
• [jira] [Created] (KAFKA-511) offset returned in Producer response may not be correct Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-511) offset returned in Producer response may not be correct Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-511) offset returned in Producer response may not be correct Jun Rao (JIRA)
  • [jira] [Assigned] (KAFKA-511) offset returned in Producer response may not be correct Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-511) offset returned in Producer response may not be correct Joel Koshy (JIRA)
  • [jira] [Updated] (KAFKA-511) offset returned in Producer response may not be correct Jun Rao (JIRA)
  • [jira] [Closed] (KAFKA-511) offset returned in Producer response may not be correct Jun Rao (JIRA)
• ??? 0.7.2 before 0.8 ??? Joe Stein
  • Re: ??? 0.7.2 before 0.8 ??? Jun Rao
  • Re: ??? 0.7.2 before 0.8 ??? Joel Koshy
  • Re: ??? 0.7.2 before 0.8 ??? Chris Burroughs
  • Re: ??? 0.7.2 before 0.8 ??? Joe Stein
• [jira] [Commented] (KAFKA-325) revisit broker config in 0.8 Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-325) revisit broker config in 0.8 Swapnil Ghike (JIRA)
• [jira] [Closed] (KAFKA-203) Improve Kafka internal metrics Jun Rao (JIRA)
• [jira] [Created] (KAFKA-510) broker needs to know the replication factor per partition Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-510) broker needs to know the replication factor per partition Jun Rao (JIRA)
  • [jira] [Assigned] (KAFKA-510) broker needs to know the replication factor per partition Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-510) broker needs to know the replication factor per partition Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-510) broker needs to know the replication factor per partition Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-510) broker needs to know the replication factor per partition Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-510) broker needs to know the replication factor per partition Jun Rao (JIRA)
  • [jira] [Assigned] (KAFKA-510) broker needs to know the replication factor per partition Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-510) broker needs to know the replication factor per partition Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-510) broker needs to know the replication factor per partition Jun Rao (JIRA)
  • [jira] [Assigned] (KAFKA-510) broker needs to know the replication factor per partition Yang Ye (JIRA)
  • [jira] [Updated] (KAFKA-510) broker needs to know the replication factor per partition Yang Ye (JIRA)
  • [jira] [Commented] (KAFKA-510) broker needs to know the replication factor per partition Joel Koshy (JIRA)
  • [jira] [Updated] (KAFKA-510) broker needs to know the replication factor per partition Yang Ye (JIRA)
  • [jira] [Commented] (KAFKA-510) broker needs to know the replication factor per partition Joel Koshy (JIRA)
  • [jira] [Updated] (KAFKA-510) broker needs to know the replication factor per partition Yang Ye (JIRA)
  • [jira] [Commented] (KAFKA-510) broker needs to know the replication factor per partition Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-510) broker needs to know the replication factor per partition Yang Ye (JIRA)
  • [jira] [Updated] (KAFKA-510) broker needs to know the replication factor per partition Yang Ye (JIRA)
  • [jira] [Commented] (KAFKA-510) broker needs to know the replication factor per partition Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-510) broker needs to know the replication factor per partition Yang Ye (JIRA)
  • [jira] [Updated] (KAFKA-510) broker needs to know the replication factor per partition Yang Ye (JIRA)
  • [jira] [Closed] (KAFKA-510) broker needs to know the replication factor per partition Jun Rao (JIRA)
  • [jira] [Resolved] (KAFKA-510) broker needs to know the replication factor per partition Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-510) broker needs to know the replication factor per partition Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-510) broker needs to know the replication factor per partition Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-510) broker needs to know the replication factor per partition Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-510) broker needs to know the replication factor per partition Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-510) broker needs to know the replication factor per partition Yang Ye (JIRA)
  • [jira] [Commented] (KAFKA-510) broker needs to know the replication factor per partition Neha Narkhede (JIRA)
  • [jira] [Commented] (KAFKA-510) broker needs to know the replication factor per partition Yang Ye (JIRA)
  • [jira] [Updated] (KAFKA-510) broker needs to know the replication factor per partition Yang Ye (JIRA)
  • [jira] [Commented] (KAFKA-510) broker needs to know the replication factor per partition Neha Narkhede (JIRA)
• [jira] [Created] (KAFKA-509) server should shut down on encountering invalid highwatermark file Swapnil Ghike (JIRA)
  • [jira] [Updated] (KAFKA-509) server should shut down on encountering invalid highwatermark file Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-509) server should shut down on encountering invalid highwatermark file Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-509) server should shut down on encountering invalid highwatermark file Swapnil Ghike (JIRA)
  • [jira] [Assigned] (KAFKA-509) server should shut down on encountering invalid highwatermark file Yang Ye (JIRA)
  • [jira] [Updated] (KAFKA-509) server should shut down on encountering invalid highwatermark file Yang Ye (JIRA)
  • [jira] [Commented] (KAFKA-509) server should shut down on encountering invalid highwatermark file Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-509) server should shut down on encountering invalid highwatermark file Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-509) server should shut down on encountering invalid highwatermark file Yang Ye (JIRA)
  • [jira] [Closed] (KAFKA-509) server should shut down on encountering invalid highwatermark file Jun Rao (JIRA)
  • [jira] [Resolved] (KAFKA-509) server should shut down on encountering invalid highwatermark file Jun Rao (JIRA)
• [jira] [Created] (KAFKA-508) separate out partiondata from fetchresponse and producer request Joe Stein (JIRA)
  • [jira] [Updated] (KAFKA-508) split out partiondata from fetchresponse and producerrequest Joe Stein (JIRA)
  • [jira] [Updated] (KAFKA-508) split out partiondata from fetchresponse and producerrequest Joel Koshy (JIRA)
  • [jira] [Commented] (KAFKA-508) split out partiondata from fetchresponse and producerrequest Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-508) split out partiondata from fetchresponse and producerrequest Joe Stein (JIRA)
  • [jira] [Comment Edited] (KAFKA-508) split out partiondata from fetchresponse and producerrequest Joe Stein (JIRA)
  • [jira] [Updated] (KAFKA-508) split out partiondata from fetchresponse and producerrequest Joe Stein (JIRA)
  • [jira] [Updated] (KAFKA-508) split out partiondata from fetchresponse and producerrequest Joe Stein (JIRA)
  • [jira] [Commented] (KAFKA-508) split out partiondata from fetchresponse and producerrequest Joel Koshy (JIRA)
  • [jira] [Commented] (KAFKA-508) split out partiondata from fetchresponse and producerrequest Joe Stein (JIRA)
  • [jira] [Updated] (KAFKA-508) split out partiondata from fetchresponse and producerrequest Joe Stein (JIRA)
  • [jira] [Commented] (KAFKA-508) split out partiondata from fetchresponse and producerrequest Joel Koshy (JIRA)
  • [jira] [Commented] (KAFKA-508) split out partiondata from fetchresponse and producerrequest Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-508) split out partiondata from fetchresponse and producerrequest Joe Stein (JIRA)
  • [jira] [Closed] (KAFKA-508) split out partiondata from fetchresponse and producerrequest Joe Stein (JIRA)
• PartitionData Jay Kreps
  • Re: PartitionData Joel Koshy
  • Re: PartitionData Joe Stein
  • Re: PartitionData Joel Koshy
  • Re: PartitionData Jun Rao
  • Re: PartitionData Magnus Edenhill
  • Re: PartitionData Jun Rao
• [jira] [Created] (KAFKA-507) Shut down ZK last to avoid hanging brokers running processes John Fung (JIRA)
  • [jira] [Assigned] (KAFKA-507) Shut down ZK last to avoid hanging brokers running processes John Fung (JIRA)
  • [jira] [Updated] (KAFKA-507) Shut down ZK last to avoid hanging brokers running processes Joel Koshy (JIRA)
  • [jira] [Resolved] (KAFKA-507) Shut down ZK last to avoid hanging brokers running processes John Fung (JIRA)
• [jira] [Created] (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 Jun Rao (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 Neha Narkhede (JIRA)

• Earlier messages
• Later messages