Re: Problem with Kafka group.id

2020-03-24 Thread Gabor Somogyi
Hi Sjoerd, We've added kafka.group.id config to Spark 3.0... kafka.group.id string none streaming and batch The Kafka group id to use in Kafka consumer while reading from Kafka. Use this with caution. By default, each query generates a unique group id for reading data. This ensures that each

Re: Problem with Kafka group.id

2020-03-24 Thread Sjoerd van Leent
@spark.apache.org Subject: Re: Problem with Kafka group.id Hello! Maybe you can find more information on the same issue reported here: https://jaceklaskowski.gitbooks.io/spark-structured-streaming/spark-sql-streaming-KafkaSourceProvider.html<https://eur03.safelinks.protection.outlook.com/?url=https%3A

Re: Problem with Kafka group.id

2020-03-24 Thread Spico Florin
Hello! Maybe you can find more information on the same issue reported here: https://jaceklaskowski.gitbooks.io/spark-structured-streaming/spark-sql-streaming-KafkaSourceProvider.html validateGeneralOptions makes sure that group.id has not been specified and reports an IllegalArgumentException

Re: Problem with Kafka group.id

2020-03-23 Thread Sethupathi T
I had exact same issue, the temp fix what I did was, took open source code from github, modified the group.id mandatory logic and built customized library. Thanks, On Tue, Mar 17, 2020 at 7:34 AM Sjoerd van Leent < sjoerd.van.le...@alliander.com> wrote: > Dear reader, > > > > I must force the

Problem with Kafka group.id

2020-03-17 Thread Sjoerd van Leent
Dear reader, I must force the group.id of Kafka, as Kafka is under ACL control, however, doing so gives me the error: Kafka option 'group.id' is not supported as user-specified consumer groups are not used to track offsets. This won't work, as not being able to set it, basically disqualifies