Hello, This might related to: https://issues.apache.org/jira/browse/NIFI-1020
Does anyone know if the upgrade of the Kafka client for the next NiFi release addresses this issue? -Bryan On Mon, Oct 19, 2015 at 4:01 AM, 彭光裕 <[email protected]> wrote: > hi, > > > > I have a test topic in kafka with 6 partitions. When I use default > PutKafka of nifi to put messages(let’s say 100/batch), I found it usually > only put to one partition. > > I have tried the kafka key property to be ‘${nextInt():mod(6)}’ or > ‘${uuid()}’, but it doesn’t seems work. How do I put the messages to the test > topic with like round robin policy? > > > > Any advice will be welcome. Thank you. > > > > > > Roland. > > > > > *本信件可能包含中華電信股份有限公司機密資訊,非指定之收件者,請勿蒐集、處理或利用本信件內容,並請銷毀此信件. > 如為指定收件者,應確實保護郵件中本公司之營業機密及個人資料,不得任意傳佈或揭露,並應自行確認本郵件之附檔與超連結之安全性,以共同善盡資訊安全與個資保護責任. > Please be advised that this email message (including any attachments) > contains confidential information and may be legally privileged. If you are > not the intended recipient, please destroy this message and all attachments > from your system and do not further collect, process, or use them. Chunghwa > Telecom and all its subsidiaries and associated companies shall not be > liable for the improper or incomplete transmission of the information > contained in this email nor for any delay in its receipt or damage to your > system. If you are the intended recipient, please protect the confidential > and/or personal information contained in this email with due care. Any > unauthorized use, disclosure or distribution of this message in whole or in > part is strictly prohibited. Also, please self-inspect attachments and > hyperlinks contained in this email to ensure the information security and > to protect personal information.* >
