Kafka
  1. Kafka
  2. KAFKA-158

go consumer & producer to support compression

    Details

    • Type: Bug Bug
    • Status: Resolved
    • Priority: Minor Minor
    • Resolution: Fixed
    • Affects Version/s: 0.7
    • Fix Version/s: None
    • Component/s: clients
    • Labels:

      Description

      As related to KAFKA-79, the go consumer and producer needs to support the compression attribute per https://cwiki.apache.org/confluence/display/KAFKA/Compression.

      Can someone assign this to me, i'll add support and create a patch.

      thanks

      1. KAFKA-158.patch
        4 kB
        AaronR
      2. KAFKA-158-try2.patch
        7 kB
        AaronR
      3. kafka_158_go_compress.patch
        22 kB
        Jeffrey Damick
      4. kafka_158_go_compress_working.patch
        28 kB
        Jeffrey Damick
      5. kafka_158_go_compress_working_2.patch
        28 kB
        Jeffrey Damick

        Activity

        Jeffrey Damick created issue -
        AaronR made changes -
        Field Original Value New Value
        Attachment KAFKA-158.patch [ 12499621 ]
        AaronR made changes -
        Attachment KAFKA-158-try2.patch [ 12499710 ]
        Jeffrey Damick made changes -
        Status Open [ 1 ] Patch Available [ 10002 ]
        Jeffrey Damick made changes -
        Status Patch Available [ 10002 ] Open [ 1 ]
        Jeffrey Damick made changes -
        Attachment kafka_158_go_compress.patch [ 12499881 ]
        Jeffrey Damick made changes -
        Comment [ i was referring to the 'message set' wire format:
        * 4 byte size containing an integer N
        * N message bytes as described in the message class

        my 2 cents - It seems convoluted to store uncompressed messages inside compressed messages.. ]
        Jeffrey Damick made changes -
        Attachment kafka_158_go_compress_working.patch [ 12500368 ]
        Jeffrey Damick made changes -
        Attachment kafka_158_go_compress_working_2.patch [ 12501095 ]
        Neha Narkhede made changes -
        Status Open [ 1 ] Resolved [ 5 ]
        Resolution Fixed [ 1 ]

          People

          • Assignee:
            Unassigned
            Reporter:
            Jeffrey Damick
          • Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

            Dates

            • Created:
              Updated:
              Resolved:

              Development