Hacktoberfest 2026：メンテナが10月に向けて印を付けた、オープンで初心者向けの issue。 Hacktoberfest の issue を見る

Eventhub Binary message not respect

オープン
  • 何か問題がありますか？
#644 コメント 0 件 リアクション 0 件 担当者 1 名 GitHub で見る

まだ誰も着手していません。

評価

この issue はまだ評価されていません。

説明

area:java-functions Bug reviewed

When eventhub send binary message, java function app is getting garbled string message

example:

    @FunctionName("eventhuexampleCx")
    public void eventHubProcessorCx(
            @EventHubTrigger(name = "pnrTrigger", eventHubName = "cri-319862312", consumerGroup = "test", connection = "EventHubConnectionAppSetting", cardinality = Cardinality.ONE) String paxHubMsgs,
            final ExecutionContext context) {

        Logger logger = context.getLogger();
        logger.info("***************" + (paxHubMsgs));
        byte[] bytes = paxHubMsgs.getBytes();
        String message = new String(bytes, StandardCharsets.UTF_16);
        logger.info(message);
    }

image

Python script for sending binary message to eventhub

import asyncio
import struct
from azure.eventhub.aio import EventHubProducerClient
from azure.eventhub import EventData

async def run():
    # Create a producer client to send messages to the event hub.
    # Specify a connection string to your event hubs namespace and
    # the event hub name.
    producer = EventHubProducerClient.from_connection_string(conn_str="your-event-hub-connection-string", eventhub_name="cri-319862312")
    async with producer:
        # Create a batch.
        event_data_batch = await producer.create_batch()
        bin_data = struct.pack('200B', *range(200))
        bin_data = b'\x90\x91\x92\x93\x94\x95\x96\x97\x98\x99\x9a\x9b'


        # Add events to the batch.
        event_data_batch.add(EventData(bin_data))


        # Send the batch of events to the event hub.
        await producer.send_batch(event_data_batch)

loop = asyncio.get_event_loop()
loop.run_until_complete(run())
主要言語
Java
スター
103
フォーク
74
平均マージ
1日 11時間
マージ済み PR（30日）
3

環境構築

はじめの一歩

  1. issue を最後まで読み、次にプロジェクトのコントリビューションガイドを読みます。
  2. 着手することを issue にコメントします — 二人が同じ作業をするのを防げます。
  3. リポジトリをフォークし、ブランチを切って変更します。
  4. issue 番号を参照したプルリクエストを送ります。

Azure/azure-functions-java-worker のほかの issue

Azure/azure-functions-java-worker の issue をすべて見る

似ている issue

Java の issue をもっと見る

新しい issue をメールで受け取る

初心者向けの GitHub issue を短くまとめたダイジェスト。