Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-288

java impacted changes from new producer and consumer request format

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Resolved
    • Major
    • Resolution: Won't Fix
    • 0.8.0
    • None
    • None

    Description

      1) javaapi.SyncProducer: We should get rid of send(topic: String, messages: ByteBufferMessageSet) and only keep send(producerRequest: kafka.javaapi.ProducerRequest).

      This affects KafkaRecordWriter and DataGenerator

      2) javaapi.ProducerRequest: We will need to define a java version of TopicData so that java producers can create request conveniently. The java version of TopicData will use the java version of ByteBufferMessageSet.

      Attachments

        Issue Links

          is related to

          Sub-task - The sub-task of the issue KAFKA-240 implement new producer and consumer request format

          • Major - Major loss of function.
          • Resolved

          Activity

            People

              Unassigned Unassigned
              charmalloc Joe Stein
              Votes:
              0 Vote for this issue
              Watchers:
              0 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: