Re: Dynamic partition is not working in Kafka Input Operator

Hi Sandesh, No. Kafka Input Operator(0.8 version) supports dynamic partition based on Kafka partitions. Created a JIRA (APEXCORE-494 ) for tracking this issue. Regards, Chaitanya On Tue, Jul 19, 2016 at 9:47 AM, Sandesh Hegde wrote

Re: Dynamic partition is not working in Kafka Input Operator

Was this resolved? My understanding is that, Kafka Input operator doesn't support the changes in Kafka partitions after the initial launch. On Mon, Jul 18, 2016 at 1:54 AM Chaitanya Chebolu wrote: > Hi All, > >I am facing dynamic partition issues in 0.8 version of Kafka Input > Operator. My

Dynamic partition is not working in Kafka Input Operator

Hi All, I am facing dynamic partition issues in 0.8 version of Kafka Input Operator. My application has the following DAG: KafkaSinglePortStringInputOperator(Input) -> ConsoleOutputOperator(Output) I launched the application with below configuration: Kafka topic created with single part