Thanks Fabian again for the clarification.
On Thu, Jun 24, 2021 at 8:16 PM Fabian Paul
wrote:
> Hi Debraj,
>
> Sorry for the confusion the FlinkKafkaConsumer is the old source and the
> overhauled one you can find here [1].
> You would need to replace the FlinkKafkaConsumer with the KafkaSource
Hi Debraj,
Sorry for the confusion the FlinkKafkaConsumer is the old source and the
overhauled one you can find here [1].
You would need to replace the FlinkKafkaConsumer with the KafkaSource to not
see the message anymore.
Best
Fabian
[1]
Thanks Fabian for replying. But I am using KafkaSource only.
The code is something like below.
class MetricSource {
final Set metricSdms = new HashSet();
...
env.addSource(MetricKafkaSourceFactory.createConsumer(jobParams))
.name(MetricSource.class.getSimpleName())
Hi Debraj,
By Source Legacy Thread we refer to all sources which do not implement the new
interface yet [1]. Currently only the Hive, Kafka and FileSource
are already migrated. In general, there is no sever downside of using the older
source but in the future we plan only to implement ones
36050.n4.nabble.com/quot-Legacy-Source-Thread-quot-line-in-logs-td33941.html#a44594>
in the deprecated mailing list with no answer. So starting a new email
thread here.
Hi KristoffSC,
the short answer is: you have probably differently configured logger. They
log in a different format or level.
The longer answer: all source connectors currently use the legacy source
thread. That will only change with FLIP-27 [1] being widely adapted. It was
originally planned to
Hi all,
When I run Flink from IDE i can see this prefix in logs
"Legacy Source Thread"
Running the same job as JobCluster on docker, this prefix is not present.
What this prefix means?
Btw, I'm using [1] as ActiveMQ connector.
Thanks.
[1]
