chia7712 commented on code in PR #13434:
URL: https://github.com/apache/kafka/pull/13434#discussion_r1590212654
##########
connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaOffsetBackingStore.java:
##########
@@ -141,24 +145,13 @@ private static String noClientId() {
protected KafkaBasedLog<byte[], byte[]> offsetLog;
// Visible for testing
final HashMap<ByteBuffer, ByteBuffer> data = new HashMap<>();
+ private final Map<String, Set<Map<String, Object>>> connectorPartitions =
new HashMap<>();
+ private Converter keyConverter;
private final Supplier<TopicAdmin> topicAdminSupplier;
private final Supplier<String> clientIdBase;
private SharedTopicAdmin ownTopicAdmin;
protected boolean exactlyOnce;
- /**
- * Create an {@link OffsetBackingStore} backed by a Kafka topic. This
constructor will cause the
- * store to instantiate and close its own {@link TopicAdmin} during {@link
#configure(WorkerConfig)}
- * and {@link #stop()}, respectively.
- *
- * @deprecated use {@link #KafkaOffsetBackingStore(Supplier, Supplier)}
instead
- */
- @Deprecated
- public KafkaOffsetBackingStore() {
Review Comment:
Sorry for making noise on this PR. out of curiosity, should we remove
deprecated constructors from `KafkaStatusBackingStore` and
`KafkaConfigBackingStore` too? not sure whether those internal classes need the
deprecation cycle?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
