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

java impacted changes from new producer and consumer request format

    XMLWordPrintableJSON

    Details

    • Type: Improvement
    • Status: Resolved
    • Priority: Major
    • Resolution: Won't Fix
    • Affects Version/s: 0.8.0
    • Fix Version/s: None
    • Component/s: 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

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

                Dates

                • Created:
                  Updated:
                  Resolved: