@Test public void testDefaultGroupIdConfig() throws Exception { Store<String, String> inMemoryStore = new InMemoryCache<>(StringSerializer.INSTANCE); Properties props = new Properties(); KafkaStore kafkaStore = StoreUtils.createAndInitKafkaStoreInstance(bootstrapServers, inMemoryStore, props); assertTrue(kafkaStore.getKafkaStoreReaderThread().getConsumerProperty(org.apache.kafka.clients.consumer.ConsumerConfig.GROUP_ID_CONFIG).startsWith("schema-registry-")); }
KafkaStoreReaderThread<K, V> getKafkaStoreReaderThread() { return this.kafkaTopicReader; }
KafkaStore implements Store<K, V> { KafkaStoreReaderThread<K, V> getKafkaStoreReaderThread() { return this.kafkaTopicReader; } }
KafkaStore implements Store<K, V> { KafkaStoreReaderThread<K, V> getKafkaStoreReaderThread() { return this.kafkaTopicReader; } KafkaStore(SchemaRegistryConfig config,
                    StoreUpdateHandler<K, V> storeUpdateHandler,
                    Serializer<K, V> serializer,
                    Store<K, V> localStore,
                    K noopKey); }
KafkaStore implements Store<K, V> { KafkaStoreReaderThread<K, V> getKafkaStoreReaderThread() { return this.kafkaTopicReader; } KafkaStore(SchemaRegistryConfig config,
                    StoreUpdateHandler<K, V> storeUpdateHandler,
                    Serializer<K, V> serializer,
                    Store<K, V> localStore,
                    K noopKey); @Override void init(); static void addSchemaRegistryConfigsToClientProperties(SchemaRegistryConfig config,
                                                                Properties props); void waitUntilKafkaReaderReachesLastOffset(int timeoutMs); void waitUntilKafkaReaderReachesLastOffset(String subject, int timeoutMs); void markLastWrittenOffsetInvalid(); @Override V get(K key); @Override V put(K key, V value); @Override CloseableIterator<V> getAll(K key1, K key2); @Override void putAll(Map<K, V> entries); @Override V delete(K key); @Override CloseableIterator<K> getAllKeys(); @Override void flush(); @Override void close(); void waitForInit(); boolean initialized(); long lastOffset(String subject); void setLastOffset(String subject, long lastOffset); Lock leaderLock(); Lock lockFor(String subject); }
KafkaStore implements Store<K, V> { KafkaStoreReaderThread<K, V> getKafkaStoreReaderThread() { return this.kafkaTopicReader; } KafkaStore(SchemaRegistryConfig config,
                    StoreUpdateHandler<K, V> storeUpdateHandler,
                    Serializer<K, V> serializer,
                    Store<K, V> localStore,
                    K noopKey); @Override void init(); static void addSchemaRegistryConfigsToClientProperties(SchemaRegistryConfig config,
                                                                Properties props); void waitUntilKafkaReaderReachesLastOffset(int timeoutMs); void waitUntilKafkaReaderReachesLastOffset(String subject, int timeoutMs); void markLastWrittenOffsetInvalid(); @Override V get(K key); @Override V put(K key, V value); @Override CloseableIterator<V> getAll(K key1, K key2); @Override void putAll(Map<K, V> entries); @Override V delete(K key); @Override CloseableIterator<K> getAllKeys(); @Override void flush(); @Override void close(); void waitForInit(); boolean initialized(); long lastOffset(String subject); void setLastOffset(String subject, long lastOffset); Lock leaderLock(); Lock lockFor(String subject);  }