[
https://issues.apache.org/jira/browse/FLINK-24681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
qinghuan wang updated FLINK-24681:
----------------------------------
Description:
When create a Kafka Table
{code:java}
CREATE TABLE KafkaTable (
...
) WITH (
'connector' = 'kafka',
'topic' = 'user_behavior',
'properties.bootstrap.servers' = '192.168.3.244:9092',
'properties.group.id' = 'testGroup',
'format' = 'csv'
);
{code}
An exception throws:
{code:java}
Caused by: org.apache.kafka.clients.consumer.NoOffsetForPartitionException:
Undefined offset with no reset policy for partitions: [user_behavior-0]Caused
by: org.apache.kafka.clients.consumer.NoOffsetForPartitionException: Undefined
offset with no reset policy for partitions: [haikang-face-recognition-0] at
org.apache.kafka.clients.consumer.internals.SubscriptionState.resetMissingPositions(SubscriptionState.java:631)
at
org.apache.kafka.clients.consumer.KafkaConsumer.updateFetchPositions(KafkaConsumer.java:2343)
at
org.apache.kafka.clients.consumer.KafkaConsumer.position(KafkaConsumer.java:1725)
at
org.apache.kafka.clients.consumer.KafkaConsumer.position(KafkaConsumer.java:1684)
at
org.apache.flink.connector.kafka.source.reader.KafkaPartitionSplitReader.removeEmptySplits(KafkaPartitionSplitReader.java:375)
at
org.apache.flink.connector.kafka.source.reader.KafkaPartitionSplitReader.handleSplitsChanges(KafkaPartitionSplitReader.java:260)
at
org.apache.flink.connector.base.source.reader.fetcher.AddSplitsTask.run(AddSplitsTask.java:51)
at
org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.runOnce(SplitFetcher.java:142)
... 7 common frames omitted{code}
was:
When create a Kafka Table
{code:java}
CREATE TABLE KafkaTable (
...
) WITH (
'connector' = 'kafka',
'topic' = 'user_behavior',
'properties.bootstrap.servers' = '192.168.3.244:9092',
'properties.group.id' = 'testGroup',
'format' = 'csv'
);
{code}
An exception throws:
{code:java}
Caused by: org.apache.kafka.clients.consumer.NoOffsetForPartitionException:
Undefined offset with no reset policy for partitions: [user_behavior-0]Caused
by: org.apache.kafka.clients.consumer.NoOffsetForPartitionException: Undefined
offset with no reset policy for partitions: [haikang-face-recognition-0] at
org.apache.kafka.clients.consumer.internals.SubscriptionState.resetMissingPositions(SubscriptionState.java:631)
at
org.apache.kafka.clients.consumer.KafkaConsumer.updateFetchPositions(KafkaConsumer.java:2343)
at
org.apache.kafka.clients.consumer.KafkaConsumer.position(KafkaConsumer.java:1725)
at
org.apache.kafka.clients.consumer.KafkaConsumer.position(KafkaConsumer.java:1684)
at
org.apache.flink.connector.kafka.source.reader.KafkaPartitionSplitReader.removeEmptySplits(KafkaPartitionSplitReader.java:375)
at
org.apache.flink.connector.kafka.source.reader.KafkaPartitionSplitReader.handleSplitsChanges(KafkaPartitionSplitReader.java:260)
at
org.apache.flink.connector.base.source.reader.fetcher.AddSplitsTask.run(AddSplitsTask.java:51)
at
org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.runOnce(SplitFetcher.java:142)
... 7 common frames omitted{code}
> org.apache.kafka.clients.consumer.NoOffsetForPartitionException: Undefined
> offset with no reset policy for partitions
> ----------------------------------------------------------------------------------------------------------------------
>
> Key: FLINK-24681
> URL: https://issues.apache.org/jira/browse/FLINK-24681
> Project: Flink
> Issue Type: Improvement
> Components: Connectors / Kafka
> Affects Versions: 1.14.0
> Reporter: qinghuan wang
> Priority: Minor
> Labels: pull-request-available
>
> When create a Kafka Table
> {code:java}
> CREATE TABLE KafkaTable (
> ...
> ) WITH (
> 'connector' = 'kafka',
> 'topic' = 'user_behavior',
> 'properties.bootstrap.servers' = '192.168.3.244:9092',
> 'properties.group.id' = 'testGroup',
> 'format' = 'csv'
> );
> {code}
> An exception throws:
> {code:java}
> Caused by: org.apache.kafka.clients.consumer.NoOffsetForPartitionException:
> Undefined offset with no reset policy for partitions: [user_behavior-0]Caused
> by: org.apache.kafka.clients.consumer.NoOffsetForPartitionException:
> Undefined offset with no reset policy for partitions:
> [haikang-face-recognition-0] at
> org.apache.kafka.clients.consumer.internals.SubscriptionState.resetMissingPositions(SubscriptionState.java:631)
> at
> org.apache.kafka.clients.consumer.KafkaConsumer.updateFetchPositions(KafkaConsumer.java:2343)
> at
> org.apache.kafka.clients.consumer.KafkaConsumer.position(KafkaConsumer.java:1725)
> at
> org.apache.kafka.clients.consumer.KafkaConsumer.position(KafkaConsumer.java:1684)
> at
> org.apache.flink.connector.kafka.source.reader.KafkaPartitionSplitReader.removeEmptySplits(KafkaPartitionSplitReader.java:375)
> at
> org.apache.flink.connector.kafka.source.reader.KafkaPartitionSplitReader.handleSplitsChanges(KafkaPartitionSplitReader.java:260)
> at
> org.apache.flink.connector.base.source.reader.fetcher.AddSplitsTask.run(AddSplitsTask.java:51)
> at
> org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.runOnce(SplitFetcher.java:142)
> ... 7 common frames omitted{code}
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
