[GitHub] [apisix] robertluoxu commented on issue #9779: bug: kafka-proxy Setting PubSubReq.CmdKafkaFetch.offset does not take effect

["robertluoxu (via GitHub)" <gi...@apache.org>]

robertluoxu commented on issue #9779:
URL: https://github.com/apache/apisix/issues/9779#issuecomment-1624825107

   my router
   
   ```
   {
     "uri": "/kafka",
     "name": "kafka",
     "methods": [
       "GET",
       "POST",
       "PUT",
       "DELETE",
       "PATCH",
       "HEAD",
       "OPTIONS",
       "CONNECT",
       "TRACE",
       "PURGE"
     ],
     "upstream_id": "467794562773943068",
     "status": 1
   }
   ```
   
   upstream:
   
   ```
   {
     "nodes": [
       {
         "host": "172.18.25.37",
         "port": 31008,
         "weight": 1
       }
     ],
     "timeout": {
       "connect": 6,
       "send": 6,
       "read": 6
     },
     "type": "roundrobin",
     "scheme": "kafka",
     "pass_host": "pass",
     "name": "kafka-test",
     "keepalive_pool": {
       "idle_timeout": 60,
       "requests": 1000,
       "size": 320
     }
   }
   ```
   
   vue code:
   
   ```
   created: function() {
       this.$options.sockets.onmessage = (res) => { 
           // eslint-disable-next-line no-console
           console.log('sockets.onmessage:' , res)
           res.data.arrayBuffer().then(buffer=>{
               // ArrayBuffer
               let s = new Uint8Array(buffer);
               let devcodePubsubRespdata  = decodePubSubResp(s);
               // eslint-disable-next-line no-console
               console.log('devcodePubsubRespdata', devcodePubsubRespdata)
               devcodePubsubRespdata.kafka_fetch_resp.messages.forEach(element => {
                   // eslint-disable-next-line no-console
                   console.log('kafka offset', element.offset.high)
                   // eslint-disable-next-line no-console
                   console.log('kafka timestamp', element.timestamp)
                   // eslint-disable-next-line no-console
                   console.log('kafka value', String.fromCharCode.apply(null,element.value))
               });
           })};
       // eslint-disable-next-line no-console
       this.$options.sockets.onerror = (data) => {console.log('sockets.onerror:' , data)}
       // eslint-disable-next-line no-console
       this.$options.sockets.onopen  = (data) => {console.log('sockets.onopen :' , data)}
       // eslint-disable-next-line no-console
       this.$options.sockets.onclose   = (data) => {console.log('sockets.onclose  :' , data)}
     },
     methods: {
       ws(){
           let cmdKafkaFetch = {topic: "testTopic", partition: 0 , offset: 5}
           let cmdKafkaListOffset = {topic: "testTopic", partition: 0 }
           let pubSubReq = { sequence:1,cmd_kafka_fetch: cmdKafkaFetch, cmd_kafka_list_offset: cmdKafkaListOffset}
           this.pubsubdata  = encodePubSubReq(pubSubReq);
           // eslint-disable-next-line no-console
           console.log('$socket.send', this.pubsubdata);
           this.$socket.send(this.pubsubdata);
       },
       decodeWs(){
           let result  = decodePubSubReq(this.pubsubdata);
           // eslint-disable-next-line no-console
           console.log('decodePubSubReq', result);
           // this.$socket.send('Hello WebSocket')
       },
     }
   ```
   
   kafka ：
   ![image](https://github.com/apache/apisix/assets/52069259/f03ecc4c-3d1d-414c-82d1-b553f2887dd6)
   
   
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: notifications-unsubscribe@apisix.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org